Hi . 我也遇到了这个问题， 最后怎么解决的？ 版本 Flink 1.12.1 .
flink2021 <[email protected]> 于2021年2月19日周五 下午12:39写道： > 嗯，我猜测也是，估计是我们kafka某些参数需要调整。大佬可以帮忙看看你们一般的kafka配置是什么样的呢？ > JVM :export KAFKA_HEAP_OPTS="-Xmx14G -Xms14G -server -XX:+UseG1GC > -XX:MaxDirectMemorySize=8192m" > 其它也就是写常规的配置： > og.segment.bytes=1073741824 > log.retention.check.interval.ms=300000 > #broker能接收消息的最大字节数 > message.max.bytes=200000000 > #broker可复制的消息的最大字节数 > replica.fetch.max.bytes=204857600 > #消费者端的可读取的最大消息 > fetch.message.max.bytes=204857600 > max.poll.records=500 > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
