生产者连接池-kafka

uinbv5nw 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(983)

我不明白Kafka是如何为制作人维护到代理的连接池的。
当我创建producer的新对象并向broker发送消息时

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

它会从连接池返回连接吗？
kafka中生产者连接池的设置在哪里？

1条答案

首先，这取决于您使用的是同步生产者还是异步生产者。假设您正在使用同步生成器。
没有这样的设置来维护producer池。它将维护尽可能多的线程。它将从密钥对应的分区中找出代理，然后为该代理使用专用线程。有关更多详细信息，请查看kafka源类producerpool中的字段syncproducers。