我对Kafka还很陌生,我不确定为什么最大消息大小会有一个消费者和生产者参数。有两个参数看起来就像是引入了开发人员可能会忽略的错误(即设置比max.message.bytes更低的fetch.max.message.bytes )。一定有一个我遗漏的用例或设计模式,促使Kafka团队保持这两个配置值。
发布于 2020-11-10 19:59:38
所以fetch.max.message.bytes并不存在(至少在最新的Kafka版本中,那么你在使用什么?),我猜你指的是fetch.max.bytes。无论如何,fetch.max.bytes和max.message.bytes都在代理上(而不是生产者/消费者)。max.message.bytes定义了消费者可以获得的每批消息的最大大小(您知道消息是批处理的,所以分组在一起)。fetch.max.bytes定义了消费者一次可以从代理获得的批次数量的最大限制;这不是硬限制,因为如果有更多可用批次,代理将返回其中的一部分,直到达到最大数量,以避免消费者卡住。
https://stackoverflow.com/questions/64761471
复制相似问题