AI 助理
备案控制台
开发者社区 问答 正文

请教一个问题，不知道大家有没有遇到类似的问题。Flink消费Kafka ，运行一段时间后发现有部分分

请教一个问题，不知道大家有没有遇到类似的问题。Flink消费Kafka ，运行一段时间后发现有部分分区不消费了，其他分区消费正常，重启Flink 作业所有分区都能正常消费。不能消费的分区在Kafka 服务端的coordinator 日志里面没有commit offset记录，Kafka 服务端这些分区所在的主节点服务都是正常的

展开
收起
云上静思 2022-06-21 21:50:10 576 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 云墩墩

    重启就可以了。

    此答案来自钉钉群“【2】Apache Flink China 社区”

    2022-06-22 11:46:49
    赞同 展开评论
问答分类：
消息中间件 Kafka 流计算 云消息队列 Kafka 版 实时计算 Flink版 日志服务
问答标签：
云消息队列 Kafka 版flink 云消息队列 Kafka 版运行 云消息队列 Kafka 版消费
问答地址：
开发者社区 > 微服务 > 问答
相关问答
flink 消费kafka数据，idea能正常消费，但是提交flink的jar包运行还是报这个错？
140
2
0
运行flink代码消费kafka数据，idea正常能跑，就报这个错？
198
1
0
问一个现象的解决方法，flinksql从kafka读数据写入es，当任务运行一段时间，es突然断掉？
242
1
0
Flink集群使用kafka_appender收集flink产生的日志，但是现在实时运行的任务超过了
110
3
0
大佬，我刚发的那个问题 遇到过没，flink瘦包 运行 链接 kafka 报错？我放在 lib 报
920
1
0
有没有大佬知道flink任务运行一段时间后的kafka consumer就不消费了，kafka端显示
683
1
0
canal.servermode = kafka 后客户端运行就报错,这是为啥?
146
1
0
这个任务是消费Kafka的数据写入hudi，任务起初运行没有问题，昨天取消后，在重启就报错，为什么？
334
1
0
我用运行flink sql作业：flink kafka conector->hudi->hive，对
213
1
0
运行一段时间 就出现这个kafka事务问题
613
1
0