Понимание исключений BufferExhaustedException и OutOfMemoryException в Kafka: руководство с примерами
Построение архитектуры Master-Slave с помощью Kafka: использование возможностей распределенного обмена сообщениями