有一个场景,我需要连接到外部kafka和消费数据进行进一步处理。kafka python客户端与Java客户端在实现方式上有根本区别吗?
具有相同主机的Python客户端连接到代理并通过TLS消费,但Kafka控制台消费者或任何基于java的客户端都建立了与代理的连接(成功进行SSL握手),但由于客户端无法连接和订阅而进一步失败。
我知道侦听器和广告侦听器,但python kafka能够建立连接到代理和消费fine,这让我很困惑。
谁能详细说明一下客户之间的不同之处?
Kafka TCP协议对所有客户端都是一样的。
但是,Java除了需要TLS证书外,可能还需要JKS文件。 但是,非Java客户端不能使用JKS文件。如果你正在使用Confluent Python客户端,那么它将使用librdkafka,这也是由kcat
CLI实现的,你也可以使用它来测试,而不是内置Kafka工具