Impossible de se connecter au serveur de zookeeper

Question

J'essaie d'installer kafka sur kubernetes. en utilisant le fichier de déploiement ci-dessous. Je suis capable de telnet à zookeeper sur 10.98.144.178:2181 mais toujours en dessous de l'erreur. s'il vous plaît aider comment procéder:

kafka-cluster.yml

--- 
kind: Deployment 
apiVersion: extensions/v1beta1 
metadata: 
    name: kafka-broker1 
spec: 
    template: 
    metadata: 
     labels: 
     app: kafka 
     id: "1" 
    spec: 
     containers: 
     - name: kafka 
     image: wurstmeister/kafka 
     ports: 
     - containerPort: 9092 
     env: 
     - name: KAFKA_ADVERTISED_PORT 
      value: "9092" 
     - name: KAFKA_ADVERTISED_HOST_NAME 
      value: "192.168.42.182" 
     - name: KAFKA_ZOOKEEPER_CONNECT 
      value: 10.98.144.178:2181 
     - name: KAFKA_BROKER_ID 
      value: "1" 
     - name: KAFKA_CREATE_TOPICS 
      value: topic1:3:3 

Je suis en mesure de telnet à Zookeeper sur 10.98.144.178:2181 mais toujours obtenir en dessous de l'erreur. s'il vous plaît aider comment procéder:

[2017-09-22 11:22:03,487] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) 
org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server '10.98.144.178:2181' with timeout of 6000 ms 
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1233) 
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:157) 
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:131) 
    at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:103) 
    at kafka.utils.ZkUtils$.apply(ZkUtils.scala:85) 

Answer 1

J'ai fait face à la même question et mon observation est qu'il est une question sporadique qui est proportionnelle au retard de réseau entre l'hôte ZooKeeper par rapport à l'hôte Kafka. Voici les configurations qui aident à « atténuer » la question:

zookeeper.connection.timeout.ms 
zookeeper.session.timeout.ms 

La valeur par défaut est 6000ms, qui se révèle être faible nombre en cas de retard n/w. J'ai augmenté la valeur à 30000ms pour résoudre le problème.