无法发送大Kafka消息

wz3gfoph  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(224)

我正试图通过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集群。每个节点在每个文件中都有上述设置。感谢您的帮助。谢谢:)
编辑:我已经尝试了这里看到的配置,但是问题仍然存在

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题