Я не могу понять, как кафка поддерживает пул соединений с брокером для производителя.
Когда я создаю новый объект производителя и отправляю сообщение брокеру
producer = new Producer<Integer, String>(new ProducerConfig(props));
producer.send(data);
вернет ли он соединение из пула соединений?
где в kafka хранятся настройки для пула соединений производителя?
Прежде всего, это зависит от того, используете ли вы синхронизирующий производитель или асинхронный. Предположим, вы используете производителя синхронизации.
Нет никаких настроек для поддержки пула производителей как такового. Он будет поддерживать столько потоков, сколько брокеров. Он определит брокера из раздела, которому соответствует ваш ключ, а затем использует выделенный поток для этого брокера. Для получения дополнительных сведений ознакомьтесь с полем syncProducers в исходном классе kafka ProducerPool.
