kafka-producer-perf-test.sh выдает ошибку и не дает никаких результатов.В чем причина.
Я пытаюсь запустить тест производительности на моем кластере Kafka с использованием сценариев оболочки, поставляемых с Kafka. Он генерирует CORRUPT_MESSAGE ERROR.
Error: CORRUPT_MESSAGE (org.apache.kafka.clients.producer.internals.Sender)
[2019-01-03 10:33:09,119] WARN [Producer clientId=producer-1] Got error produce response with correlation id 2396 on topic-partition my_topic-1, retrying (2147483519 attempts left). Error: CORRUPT_MESSAGE (org.apache.kafka.clients.producer.internals.Sender)
Я запускаю следующую команду для запуска теста
bin/kafka-producer-perf-test.sh --topic my_topic --num-records 50 --throughput 10 --producer-props bootstrap.servers=kafka1:9092 key.serializer=org.apache.kafka.common.serialization.StringSerializer value.serializer=org.apache.kafka.common.serialization.StringSerializer --record-size 1
В чем может быть причина этого?
Редактировать 1:
У нас есть кластер из 5 брокеров машин r5.xlarge (4 ядра, 32 ГБ ОЗУ) с опцией кучи Xmx3G.