kafka引导代理在添加ssl后断开连接(使用debezium)

8e2ybdfx  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(266)

我在openshift中运行集装箱化debezium和kafka。我使用的是debezium/kafka、debezium/zookeeper debezium/connect和debezium/postgres容器,在openshift内部工作正常。
当在一个pod的终端时,我可以使用kafka控制台消费工具列出主题,也可以使用kafka的事件。每次更改数据库时,我都可以看到一个事件,例如:

kafka-console-consumer.sh --topic topic --from-beginning --bootstrap-server kafka-deployment.project.svc:9092

问题是当试图通过指向服务的openshift外部路径访问kafka时。当我从本地计算机尝试此操作时:

kafka-console-consumer.bat --topic topic --from-beginning --bootstrap-server https://route-url:443

我得到的不是主题中的数据,而是以下消息:

[2020-08-19 13:44:40,196] WARN [Consumer clientId=consumer-console-consumer-82606-1, groupId=console-consumer-82606] Bootstrap broker route-url:443 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2020-08-19 13:44:40,425] WARN [Consumer clientId=consumer-console-consumer-82606-1, groupId=console-consumer-82606] Bootstrap broker route-url:443 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2020-08-19 13:44:40,724] WARN [Consumer clientId=consumer-console-consumer-82606-1, groupId=console-consumer-82606] Bootstrap broker route-url:443 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2020-08-19 13:44:41,067] WARN [Consumer clientId=consumer-console-consumer-82606-1, groupId=console-consumer-82606] Bootstrap broker route-url:443 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)

在我使用http路由之前,ssl握手失败,所以我设法将其更改为具有有效证书的https路由,但它似乎没有连接到服务。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题