Producer 设置 max.request.size 的默认值为 1048576。它控制请求(到代理)的最大字节数。

Broker 设置 message.max.bytes 的默认值为 1000012。这控制了(Kafka 服务器/代理)允许的最大(记录批处理)大小。

1048576 > 1000012

似乎默认情况下，生产者(具有此默认值)可能会碰巧产生大于代理(具有此默认值)将接受的消息，从而导致 MESSAGE_TOO_LARGE错误。

我是否误解了这些配置设置？还是 Kafka 的默认值真的会导致 MESSAGE_TOO_LARGE 默认值错误？

最佳答案

根据 Apache Kafka 邮件列表，这是最近修复的:

https://github.com/apache/kafka/pull/4154

https://github.com/apache/kafka/commit/bd5a1c4d368b9e91398e48400965d30d3045062e

关于apache-kafka - max.request.size 和 message.max.bytes 的默认值似乎有误，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60458132/