Apache Kafka消费者-代理在Java客户端与其他客户端的主机解析



有一个场景,我需要连接到外部kafka和消费数据进行进一步处理。kafka python客户端与Java客户端在实现方式上有根本区别吗?

具有相同主机的Python客户端连接到代理并通过TLS消费,但Kafka控制台消费者或任何基于java的客户端都建立了与代理的连接(成功进行SSL握手),但由于客户端无法连接和订阅而进一步失败。

我知道侦听器和广告侦听器,但python kafka能够建立连接到代理和消费fine,这让我很困惑。

谁能详细说明一下客户之间的不同之处?

Kafka TCP协议对所有客户端都是一样的。

但是,Java除了需要TLS证书外,可能还需要JKS文件。 但是,非Java客户端不能使用JKS文件。如果你正在使用Confluent Python客户端,那么它将使用librdkafka,这也是由kcatCLI实现的,你也可以使用它来测试,而不是内置Kafka工具

相关内容

  • 没有找到相关文章

最新更新