Kafka客户端连接池

Iho*_* M. 6 java apache-kafka

执行kafka客户端的生产者/消费者连接池是否有意义?

kafka是否在内部维护一个已初始化并可以使用的连接对象列表?

我们希望最小化连接创建的时间,以便在发送/接收消息时不会产生额外的开销.

目前我们正在使用apache commons-pool库GenericObjectPool来保持连接.

任何帮助将不胜感激.

Mic*_*son 5

Kafka 客户端维护自己与集群的连接。

生产者和消费者都保持与他们正在交互的代理的连接。如果他们停止交互,connections.max.idle.ms则连接将关闭。此设置也存在于代理上,因此您可能需要与管理员确认他们是否更改了此值。

所以在大多数情况下,一旦启动 Kafka 客户端不会创建很多新连接,而是使用启动时创建的连接