Hi! I am testing Kafka's performance with large messages and would like to specify maximum request size when I run kafka-producer-perf-test.sh:
./kafka-producer-perf-test.sh --broker-list "test1:9092" --topics test8-3 --messages 1000000 --new-producer --msage-size 1100000 --show-detailed-stats I always get this message if I specify somethine larger than 1MB: ERROR Error when sending message to topic test8-3 with key: 1 bytes, value: 1100000 bytes with error: The message is 1100027 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration. (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) I know I can specify maximum request size with kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance but I would like to use kafka-producer-perf-test.sh if possible. Thanks! Andrew
