Kafka生产者“MessageMaxBytes”属性需要大于经纪人上的max.message.bytes值？

在Kafka的生产端，可以设置“MessageMaxBytes”属性，以限制生产者发送到Kafka Broker的单个消息的最大字节数。如果在生产者端设置了“MessageMaxBytes”小于或等于经纪人上的“max.message.bytes”值，则会引发上述问题。

要解决此问题，需要在生产者端将“MessageMaxBytes”属性设置为大于经纪人上的“max.message.bytes”值。例如，在Java中，可以通过以下代码示例解决此问题：

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("max.request.size", "10485760"); // 设置发送的最大消息大小为10MB props.put("compression.type", "snappy"); // 压缩消息 Producer<String, String> producer = new KafkaProducer<String, String>(props); // 然后在生产消息时，可以设置消息大小 String message = "This is a message"; ProducerRecord<String, String> record = new ProducerRecord<String, String>("my_topic", "my_key", message); RecordMetadata metadata = producer.send(record).get(); producer.close();