Я использую Кафку 2.11, получаю следующее исключение 2019-03-15 16: 41: 19.469 ОШИБКА 32539 --- [ad | производитель-1] o.s.k.support.LoggingProducerListener: исключение выдается при отправка сообщения с ключом = 'null' и полезной нагрузкой = '[{"id": 1, "name": "Tow Мотор "," описание ":" Эвакуатор движется со второго строка "," xcoordinate ":" 2264 "... 'к теме Kafka_Json1: org.apache.kafka.common.errors.RecordTooLargeException: запрос включено сообщение, превышающее максимальный размер сообщения, которое сервер будет принимаем.
Я использую Кафку 2.11, получаю следующее исключение
2019-03-15 16: 41: 19.469 ОШИБКА 32539 --- [ad | производитель-1] o.s.k.support.LoggingProducerListener: исключение выдается при отправка сообщения с ключом = 'null' и полезной нагрузкой = '[{"id": 1, "name": "Tow Мотор "," описание ":" Эвакуатор движется со второго строка "," xcoordinate ":" 2264 "... 'к теме Kafka_Json1:
org.apache.kafka.common.errors.RecordTooLargeException: запрос включено сообщение, превышающее максимальный размер сообщения, которое сервер будет принимаем.
message.max.bytes = 100000000 // Увеличение размера в файле server.properties Say Ex 100 МБ max.request.size = 100000000 // в файле Manufacturer.properties Say Ex 100МБ max.partition.fetch.bytes = 100000000 // в файле consumer.properties, чтобы потребитель мог получить данные. Скажем, 100 МБ и перезапустите брокер kafka
message.max.bytes = 100000000 // Увеличение размера в файле server.properties Say Ex 100 МБ
max.request.size = 100000000 // в файле Manufacturer.properties Say Ex 100МБ
max.partition.fetch.bytes = 100000000 // в файле consumer.properties, чтобы потребитель мог получить данные. Скажем, 100 МБ
и перезапустите брокер kafka
По умолчанию Кафка принимает сообщение размером 1 МБ. Размер вашего сообщения больше размера по умолчанию.
Вам необходимо изменить значение свойства max.request.size, message.max.bytes и max.partition.fetch.bytes, чтобы исправить эту проблему.