【发布时间】: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