【问题标题】:Unable to connect to zookeeper server无法连接到动物园管理员服务器
【发布时间】:2018-03-04 00:12:18
【问题描述】:

我正在尝试在 kubernetes 上设置 kafka。使用下面的部署文件。 我可以在 10.98.144.178:2181 上远程登录到 zookeeper,但仍然低于错误。请协助如何进行:

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

我可以在 10.98.144.178:2181 上远程登录到 zookeeper,但仍然出现以下错误。请协助如何进行:

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

【问题讨论】:

  • 请将您的代码放入代码段,并将您的普通文本放在任何代码段之外。
  • 您从哪里获得10.98.144.178 地址;是k8s的服务IP吗?对于上面的惊人不同的192.168.42.182,类似的问题

标签: apache-kafka kubernetes apache-zookeeper


【解决方案1】:

我也遇到过同样的问题,我观察到这是一个零星的问题,与 ZooKeeper 主机与 Kafka 主机之间的网络延迟成正比。以下是有助于“缓解”问题的配置:

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

默认值是 6000 毫秒,如果有 n/w 延迟,这个值会很小。我将值增加到 30000 毫秒以解决问题。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2017-09-03
    • 2018-02-20
    • 1970-01-01
    • 1970-01-01
    • 2013-09-14
    • 2015-09-27
    • 1970-01-01
    相关资源
    最近更新 更多