OpenShift -无法从KafkaJS连接Strimzi

Question

我已经成功地在OpenShift上建立了斯特里齐卡夫卡集群。我可以看到以下服务：

• kafka-brokers
• kafka-bootstrap
• zookeeper-client
• zookeeper-nodes

这实际上不同于所谓的这里；因此，不确定这是否是Strimzi安装问题。我遵循了这里的安装步骤。

我在端口kafka-bootstrap (非TLS客户端)上为kafka-brokers和9092创建了一个路由。在这两种情况下，当我提供路由值(例如，来自ECONNREFUSED的示例中的my-cluster-myproject.192.168.99.100.nip.io:9092 )时，我都会得到一个卡夫卡伊错误。

如何将kafkajs包连接到Strimzi集群？

Answer 1

您所看到的Strimzi服务是正确的，但是为了访问Kafka代理，最好使用引导服务，它允许在客户端的引导服务器列表中只指定一个" broker“，它将选择一个代理进行第一次连接，然后获取元数据(它避免使用重启时IP可以更改的无头服务连接)。因此，如果您需要从OpenShift外部访问代理，则不必手动为引导服务创建路由，但必须使用route类型配置外部侦听器(https://strimzi.io/docs/latest/#assembly-configuring-kafka-broker-listeners-deployment-configuration-kafka)。如前所述，OpenShift路由仅用于TCP连接。为了向客户端提供TLS使用的正确证书，您可以遵循文档的以下部分：连接

Answer 2

你查过外部听者了吗？

顺便说一句，如果您需要通过路由器公开strimzi，TLS加密是必要的。OpenShift路由器不支持TCP，但支持TLS。