Flink-1.10.0-StandAlone模式 Kafka Consumer InstanceAlreadyExistsException

Flink-1.10.0 StandAlone部署 Kafka-0.11 JDK8 当我在同一个Flink集群部署两个应用，这两个应用被分配到了同一个TaskManager运行，使用不同的group.id消费同一个topic时，第一个应用启动正常，第二个应用启动时，遇到了如下警告信息，请问，这个警告是如何造成的，是否可以忽略，或者说如何解决。 WARNorg.apache.kafka.common.utils.AppInfoParser- Error registering AppInfo mbean javax.management.InstanceAlrea

Re: 自定义具有Exactly-Once语义的sink

昨天晚上看到一篇微信公众号文章，分享给你，希望对你有帮助。 “Flink 端到端 Exactly-once 机制剖析” https://mp.weixin.qq.com/s/fhUNuCOVFQUjRB-fo4Rl2g 发件人： 阿华田 发送时间： 2020-04-15 11:00 收件人： user-zh@flink.apache.org 主题： 自定义具有Exactly-Once语义的sink 如果自定义具有Exactly-Once语义的sink，继承TwoPhaseCommitSinkFunction，怎么确保真正的Exactly-Once，大佬们有已经上线使用的案例demo吗？