kafka 1.1.0重置消费进度

  1. 查看当前消费进度（需要消费者在线）
    ./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --describe


    image.png

  2. 重置消费进度（需要消费者离线）
    ./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --reset-offsets --to-earliest --topic RecordStoreTopic --execute


    image.png

  3. 查看Topic的offset，确认修改后的消费进度是否正确
    ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list fz22:9092 -topic RecordStoreTopic --time -2


    image.png
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成，浏览时请结合常识与多方信息审慎甄别。
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

相关阅读更多精彩内容

  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 136,641评论 19赞 139
  • kafka丢数据问题分析
    大致可以通过上述情况进行排除 1.kafka服务器问题 查看日志是否有报错，网络访问问题等。 2. kafka p...
    生活的探路者阅读 7,743评论 0赞 10
  • Kafka架构和原理深度剖析
    Kafka简介 Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下： 以时间复杂度为O(1)的方...
    Alukar阅读 3,153评论 0赞 43
  • Kafka深度解析
    本文转载自http://dataunion.org/?p=9307 背景介绍Kafka简介Kafka是一种分布式的...
    Bottle丶Fish阅读 5,589评论 0赞 34
  • Kafka史上最详细原理总结
    姓名：周小蓬 16019110037 转载自：http://blog.csdn.net/YChenFeng/art...
    aeytifiw阅读 34,900评论 13赞 425

友情链接更多精彩内容