Flink CDC这种报错是需要把kafka的分区增加还是怎么样。(我的问题,flink消费kafka的数据,然后发现flink的webui界面只数据量远远小于实际的)?2023-10-25 16:50:10 ERROR (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:handle) - [Consumer clientId=consumer-demo_group-2, groupId=demo_group] Offset commit failed on partition energo_db-0 at offset 14774: The coordinator is not aware of this member.。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
https://www.cnblogs.com/huxi2b/p/8405566.html
https://blog.csdn.net/qq_21383435/article/details/108808272?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522169822501316800227451217%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=169822501316800227451217&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-1-108808272-null-null.nonecase&utm_term=kafka%20he%20coordinator%20is%20not%20aware%20of%20this%20member&spm=1018.2226.3001.4450,此回答整理自钉群“Flink CDC 社区”
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。