Где установить максимальный размер сообщения в Apache Kafka?

Question

В каком файле я могу увеличить максимальный размер сообщения для Кафки? (Я отправляю записи String, byte [], и когда я отправляю byte [] из 770kb, Кафка не отправляет сообщение)

Answer 1

В kafka 0.11.0 необходимо установить следующие четыре параметра конфигурации

Параметры конфигурации брокера ( подробности ):

1. message.max.bytes - максимальный размер пакета записи, разрешенный Kafka.

2. replica.fetch.max.bytes - количество байтов сообщений, которые необходимо извлечь для каждого раздела.

Параметры конфигурации производителя ( подробности ):

1. max.request.size - максимальный размер запроса в байтах. Рекомендуется сопоставить это значение с (message.max.bytes).

Параметры конфигурации потребителя ( детали ):

1. max.partition.fetch.bytes - максимальное количество байт на раздел, возвращаемое сервером. должно быть больше, чем max.message.size, чтобы потребитель мог прочитать самое большое сообщение, отправленное брокером.