【问题标题】:Kafka Client Connection PoolingKafka 客户端连接池
【发布时间】:2017-08-04 20:50:57
【问题描述】:

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

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

我们希望尽量减少创建连接的时间,以便在发送/接收消息时不会产生额外的开销。

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

任何帮助将不胜感激。

【问题讨论】:

    标签: java apache-kafka


    【解决方案1】:

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

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

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

    【讨论】:

    • 感谢您的澄清...您能否指出任何其他文档,我可以在其中阅读有关 kafka 客户端库中连接管理的更多信息?
    猜你喜欢
    • 2017-04-03
    • 2016-12-18
    • 2012-05-22
    • 2017-12-24
    • 1970-01-01
    • 2012-06-13
    • 2017-11-22
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多