嗯，我猜测也是，估计是我们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/
