如何消费Kafka已消费过的消息

Kafka消费消息的offset是定义在Zookeeper中的,如果想重复消费Kafka的消息,可以在Redis中自己记录offset的checkpoint点(n个)。
当想重复消费消息时,通过读取Redis中的checkpoint点进行Zookeeper的offset重设,这样就可以达到重复消费消息的目的。

点击此处
隐藏目录