Flink CDC这种报错是需要把kafka的分区增加还是怎么样?

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.。

展开
收起
真的很搞笑 2023-10-31 18:42:30 127 分享 版权

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

热门讨论

热门文章

还有其他疑问?
咨询AI助理