flink消费kafka问题
我在使用flink实时统计kafka数据，现在有两个任务同时执行，消费同一个kafka的topic消息，但是两个任务不能同时消费到消息，kafka消费者组已经改成不同的了
flink任务提交使用的命令 ./bin/flink run -m yarn-cluster -yjm 2048m -ytm 4096m ./examples/streaming/test.jar
./bin/flink run -m yarn-cluster -yjm 2048m -ytm 4096m ./examples/streaming/test2.jar 怎么样才能让两个任务能同时消费到这个topic的消息？
展开
收起
1
条回答
写回答
写回答
-
目前从事大数据开发，兼顾平台搭建以及实时数据分析，主要是用scala编写程序，涉及社区开源hadoop集群，emr集群，欢迎有相同兴趣的小伙伴来交流，共同进步。最近在参与flink-java实时开发。请问这是什么应用场景？程序稳定下来之后，相同逻辑的话，消费是会趋于同步的
2019-11-08 11:11:14赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
