将 REST 代理连接到 Confluent Cloud 尝试连接到 Zookeeper

Question

我正在尝试将 kafka rest 代理连接到融合云。

kafka-rest-start ccloud-kafka-rest.properties

这是我的带有 ccloud-kafka-rest.properties 属性的文件

client.ssl.endpoint.identification.algorithm=https
client.sasl.mechanism=PLAIN
consumer.request.timeout.ms=20000
bootstrap.servers=***-****.us-east-1.aws.confluent.cloud:9092
consumer.retry.backoff.ms=500
client.security.protocol=SASL_SSL
id=kafka-rest-with-ccloud
producer.acks=1
admin.request.timeout.ms=50000
client.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="***" password="***";

在我运行 kafka-rest-start 后，它会尝试连接到 zookeeper (zookeeper.connect = localhost:2181)。

错误服务器意外死亡：（io.confluent.kafkarest.KafkaRestMain:63） org.I0Itec.zkclient.exception.ZkTimeoutException：无法连接到 Zookeeper 服务器 'localhost:2181' 超时 30000 毫秒

我还尝试将 zookeeper 主机设置为空，但没有帮助。 如何关闭连接zookeeper？

Answer 1

zookeeper.connect 属性的默认值为 localhost:2181。见here 您需要使用融合云的 zookeeper 的地址填充它。

请参阅将 rest-proxy 连接到 kafka 云的说明here