我有一个从单个Kafka主题读取的Flink应用程序。我试图阻止 FlinkKafkaConsumer 停止拉消息。我的最终目标是构建一种方法来不时部署我的 Flink 应用程序，而无需停机 - 如何在不停机的情况下部署新作业。
我尝试使用"kafkaConsumer.close(("，但这不起作用。我试图阻止消费者在不杀死整个作业的情况下拉取新消息，同时我将上传一个新作业，其中包含从同一主题读取的更新代码。我该怎么做？
是否可以在 kafka 主题的所有分区上发送特殊的"开关"消息？然后，您可以在 Kafka DeserializationSchema 中覆盖isEndOfStream(T nextElement)，并让您的新作业实例在最后一个切换消息后开始工作