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

我正在尝试将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)。

  

ERROR Server意外死亡:(io.confluent.kafkarest.KafkaRestMain:63)   org.I0Itec.zkclient.exception.ZkTimeoutException:无法连接到Zookeeper服务器“ localhost:2181”,超时时间为30000 ms

我也试图将Zookeeper主机设置为空,这没有帮助。 如何关闭与Zookeeper的连接?

ief111111 回答:将REST代理连接到Confluent Cloud尝试连接到Zookeeper

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

请参阅有关将rest-proxy连接到kafka云here

的说明
本文链接:https://www.f2er.com/3169065.html

大家都在问