2017-09-22 5 views
1

私はkubernetesでkafkaを設定しようとしています。以下の展開ファイルを使用します。 私は10.98.144.178:2181で飼い猫にtelnetすることができますが、それでもエラーを下回っています。続行するためにどのように支援してください。飼い葉桶のサーバーに接続できません

カフカ-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 

私は10.98.144.178:2181上のZooKeeperにtelnet接続することができていますが、それでもエラーの下になって。続行するためにどのように支援してください。

[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) 
+0

コードセクションにコードを置き、コードセクションの外側に通常のテキストを入れてください。 – Binarus

+0

どこから '10.98.144.178'アドレスを取得しましたか?それはk8sのサービスIPですか? **上の驚くほど**異なる '192.168.42.182'の同様の質問 –

答えて

0

は、私は同じ問題に直面していると、私の観察は、それはカフカのホスト対ZooKeeperのホスト間のネットワーク遅延に比例した散発的な問題であるということです。問題の「緩和する」助け構成は次のとおりです。

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

デフォルト値は、N/Wの遅れがある場合に低い数字であることが判明した、6000msです。この問題を解決するために、値を30000ミリ秒に増やしました。

関連する問題