java - Kafka 客户端连接池

标签 java apache-kafka

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

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

我们希望最大限度地减少连接创建时间,以便在发送/接收消息时没有额外的开销。

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

任何帮助将不胜感激。

最佳答案

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

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

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

关于java - Kafka 客户端连接池,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42787343/

相关文章:

java - 无法使用jenkins将WAR部署到远程服务器

java - XFire SOAP 服务器可以向客户端发送 HTTP 301 REDIRECT 吗?

java - 使用 Lucene 进行精确短语搜索?

apache-kafka - 具有单个代理的 Kafka 集群

asynchronous - 如何均衡处理多个并发任务?

java - 仅当 Jpanel 大小已满时才显示 Jtable 滚动条

java - 如何制作 jar 文件以在运行时加载图像

java - 如何在kafka中创建自定义序列化器?

Java 8 流和传入数据 (Kafka)

apache-kafka - 信息客户端/127.0.0.1 :48452 which had sessionid 0x15698f5ac360001 (org. apache.zookeeper.server.NIOServerCnxn 的已关闭套接字连接)