【发布时间】:2017-08-04 20:50:57
【问题描述】:
对 kafka 客户端执行生产者/消费者连接池是否有意义?
kafka 是否在内部维护一个已初始化并准备好使用的连接对象列表?
我们希望尽量减少创建连接的时间,以便在发送/接收消息时不会产生额外的开销。
目前我们正在使用 apache commons-pool library GenericObjectPool 来保持连接。
任何帮助将不胜感激。
【问题讨论】:
标签: java apache-kafka
对 kafka 客户端执行生产者/消费者连接池是否有意义?
kafka 是否在内部维护一个已初始化并准备好使用的连接对象列表?
我们希望尽量减少创建连接的时间,以便在发送/接收消息时不会产生额外的开销。
目前我们正在使用 apache commons-pool library GenericObjectPool 来保持连接。
任何帮助将不胜感激。
【问题讨论】:
标签: java apache-kafka
Kafka 客户端维护自己与集群的连接。
生产者和消费者都与他们正在交互的代理保持连接。如果他们停止交互,在connections.max.idle.ms 之后连接将被关闭。此设置也存在于代理上,因此您可能需要与您的管理员验证他们是否更改了此值。
所以在大多数情况下,一旦启动 Kafka 客户端不会创建很多新连接,而只是使用启动时创建的连接
【讨论】: