我正试图通过Kafka发送一条10770128字节的信息。我收到以下错误:
org.apache.kafka.common.errors.RecordTooLargeException: The message is 10770128 bytes when serialized which is larger than the maximum request size you have configured with the max.request.size configuration.
我已经完成并向server.properties、producer.properties和consumer.properties添加了以下设置。
replica.fetch.max.bytes =12000000
message.max.bytes=12000000
max.message.bytes=12000000
max.request.size=12000000
max.message.max.bytes=12000000
max.partition.fetch.bytes=12000000
这是一个三节点的kafka集群。每个节点在每个文件中都有上述设置。感谢您的帮助。谢谢:)
编辑:我已经尝试了这里看到的配置,但是问题仍然存在
暂无答案!
目前还没有任何答案,快来回答吧!