5个作业正在读取该主题(具有不同的消费者组),每个作业的并行度=5。 每个任务管理器使用10 2Gb的ram运行,并且任务管理器堆大小被限制为2 2Gb。org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.run(KafkaConsumerThread.java:257) flink重新启动该作业,但它在该异常中总是失败我们也尝试了增加kafka堆的大小,就像这里建议的:Flink + Kafka, java.lang.OutOfMemoryError when p