【flink-connector-kafka】是否支持Subscribe模式呢？
Flink支持Subscribe模式吗？用的connector版本是flink-connector-kafka-0.11_2.11，0.11x； 因为业务需要，我想要优雅下线掉TopicB，即不中断事件流；执行结果发现当Flink服务和A服务指定同一个group.id，同时消费TopicA时，kafka偏移量提交失败（开启了检查点）；*来自志愿者整理的FLINK邮件归档
展开
收起
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
1
条回答
写回答
-
其实本质上是手速和kafka balance切换速度的PK。 有一点要考虑的是，如果作业本身有状态，也就是使用了除kafka partition、offset外的其他状态，那么依赖kafka balance的方式（或类似方式）会导致两个作业的结果都不正确*来自志愿者整理的FLINK邮件归档
2021-12-03 18:47:36赞同 展开评论
问答分类：
相关问答