简单记录下。我们公司使用kafka-ui这个工具。
-
打开需要重新消费的topic的对应的的consumer。
image.png
2.关闭消费者应用的运行。
自由关闭
3.点击右上角，reset。选择按照时间戳，控制索引到需要的那个时间点。
image.png
- 点击重制。
image.png
5.重启。
应用即可
简单记录下。我们公司使用kafka-ui这个工具。
打开需要重新消费的topic的对应的的consumer。
image.png
2.关闭消费者应用的运行。
自由关闭
3.点击右上角，reset。选择按照时间戳，控制索引到需要的那个时间点。
image.png
image.png
5.重启。
应用即可
如何保证消息不会被重复消费（保证消息消费时的幂等性） kafka 按照数据进入kafka的顺序，kafka会给每条...
消费kafka数据，方式一 消费kafka数据，方式二 将消息写入kafka
参考：极客时间-Kafka核心技术与实战内容：kafka副本机制、消费者重平衡、kafka控制器、消息可见性（高水...
1 创建kafka topic 2 验证生产者消费者 消费结果 消费者能成功消费到消息,kafka在本机可用 3 ...
kafka集群 Kafka的设计都是为了实现kafak消息队列消费数据的语义Kafka消息队列中数据消费的三种语义...
了解生产者如何向kafka集群中发送消息的，消费者如何从集群中消费消息？zookeeper到底扮演者着什么角色？它...
[Toc] 如何在kafka中创建topic 在使用kafka发送消息和消费消息之前，必须先要创建topic，在k...
在业务中使用kafka发送消息异步消费的场景，并且需要实现在消费时实现顺序消费， 利用kafka在partitio...
1、kafka工作流程 Kafka中消息是以topic进行分类的，生产者生产消息，消费者消费消息，都是面向topi...
前言 不知道大家有没有遇到这样的场景，就是一个项目中要消费多个kafka消息，不同的消费者消费指定kafka消息。...
本文标题：kafka实战--消息消费报错-如何回滚再次消费
本文链接：https://www.haomeiwen.com/subject/nvnugjtx.html
网友评论