执行kafka客户端的生产者/消费者连接池是否有意义?
kafka是否在内部维护一个已初始化并可以使用的连接对象列表?
我们希望最小化连接创建的时间,以便在发送/接收消息时不会产生额外的开销.
目前我们正在使用apache commons-pool库GenericObjectPool来保持连接.
任何帮助将不胜感激.
Kafka 客户端维护自己与集群的连接。
生产者和消费者都保持与他们正在交互的代理的连接。如果他们停止交互,connections.max.idle.ms则连接将关闭。此设置也存在于代理上,因此您可能需要与管理员确认他们是否更改了此值。
所以在大多数情况下,一旦启动 Kafka 客户端不会创建很多新连接,而是使用启动时创建的连接