我在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路由,但它似乎没有连接到服务。
暂无答案!
目前还没有任何答案,快来回答吧!