执行kafka客户端的生产者/消费者连接池是否有意义?
kafka 是否在内部维护一个已初始化并准备好使用的连接对象列表?
我们希望最大限度地减少连接创建时间,以便在发送/接收消息时没有额外的开销。
目前我们正在使用 apache commons-pool 库 GenericObjectPool
来保持连接。
任何帮助将不胜感激。
最佳答案
Kafka 客户端维护自己与集群的连接。
生产者和消费者都保持与他们正在交互的代理的连接。如果他们停止交互,在 connections.max.idle.ms
之后连接将被关闭。此设置也存在于代理上,因此您可能需要与您的管理员核实他们是否更改了此值。
所以在大多数情况下,一旦启动 Kafka 客户端不会创建很多新连接,而只会使用在启动时创建的连接
关于java - Kafka 客户端连接池,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42787343/