java - 生产者连接池 - Kafka

Question

我无法理解kafka如何为生产者维护与代理的连接池。

当我创建一个新的生产者对象并向经纪人发送消息时

producer = new Producer<Integer, String>(new ProducerConfig(props));
        producer.send(data);

它会从连接池中返回连接吗？

kafka 中维护生产者连接池的设置在哪里？

Answer 1

首先，这取决于您使用的是同步生成器还是异步生成器。假设您正在使用同步生成器。

没有用于维护生产者池的设置。它将维护与代理一样多的线程。它将从您的 key 对应的分区中找出代理，然后使用该代理的专用线程。更多细节请查看kafka源类ProducerPool中的字段syncProducers。