max.request.size 和 message.max.bytes 的默认值似乎不正确
Default values for max.request.size and message.max.bytes seem wrong
Producer 设置的默认值 max.request.size
是 1048576。它控制请求(到代理)的最大字节数。
Broker 设置的默认值 message.max.bytes
是 1000012。这控制了允许的最大(记录批次)大小(由 Kafka server/broker)。
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
Producer 设置的默认值 max.request.size
是 1048576。它控制请求(到代理)的最大字节数。
Broker 设置的默认值 message.max.bytes
是 1000012。这控制了允许的最大(记录批次)大小(由 Kafka server/broker)。
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