Генераторы Kafka являются потокобезопасными. Отправка данных в Kafka производится асинхронно — возврат из метода Producer.send происходит сразу же после помещения генератором записи во внутренний буфер. Этот буфер отправляет записи пакетами. В зависимости от ваших настроек при отправке сообщения при заполненном буфере генератора вы можете столкнуться с блокировкой.

Листинг 2.3. Пример простого генератора