kafka 0.10.0.0之后就没有fetch.max.bytes
和fetch.message.max.bytes
了。
新的是:max.partition.fetch.bytes
,说明如下:
服务器将返回每个分区的最大数据量。一个请求使用的最大总内存将是
#partition * max.partition.fetch.bytes
。这个大小必须至少与服务器允许的最大消息大小一样大,否则生产者有可能发送大于消费者可以获取的消息。如果发生这种情况,消费者在试图获取某个分区的大消息时就会被卡住。
继续加大:max.partition.fetch.bytes
新手回答,可能有误,共同探讨一下。
试试这个参数呢 fetch.max.bytes