Kafka - это приложение для распределенной очереди сообщений, написанное на Java.

Сайт Кафки: http://kafka.apache.org/

Задавая вопрос о kafka, предоставьте соответствующую информацию, такую ​​как версия kafka и версия java. Проект вашего кластера должен быть указан с количеством брокеров, темой конфигурации.

Если у вас есть ошибка в определенной теме, выполните тот же тест для другой темы с другими параметрами и посмотрите, сможете ли вы воспроизвести.