问题描述
我在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,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路由,但似乎无法连接到该服务。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)