我不明白Kafka是如何为制作人维护到代理的连接池的。当我创建producer的新对象并向broker发送消息时
producer = new Producer<Integer, String>(new ProducerConfig(props)); producer.send(data);
它会从连接池返回连接吗?kafka中生产者连接池的设置在哪里?
sgtfey8w1#
首先,这取决于您使用的是同步生产者还是异步生产者。假设您正在使用同步生成器。没有这样的设置来维护producer池。它将维护尽可能多的线程。它将从密钥对应的分区中找出代理,然后为该代理使用专用线程。有关更多详细信息,请查看kafka源类producerpool中的字段syncproducers。
1条答案
按热度按时间sgtfey8w1#
首先,这取决于您使用的是同步生产者还是异步生产者。假设您正在使用同步生成器。
没有这样的设置来维护producer池。它将维护尽可能多的线程。它将从密钥对应的分区中找出代理,然后为该代理使用专用线程。有关更多详细信息,请查看kafka源类producerpool中的字段syncproducers。