强迫消费者只读取消费者生活后出现在主题中的那些消息

问题描述 投票:1回答:1

我们有什么方法可以强迫消费者阅读最新消息?例如假设我在消费者群体CG1中有一个主题t1和消费者C1。如果t1中有10条消息(m0到m10),那么一旦C1生效,它就会读取前5条消息,然后崩溃,现在崩溃之前让它说它已经确认为5。同时,该主题还收到5条消息(m11到m15)。现在C1重新启动,之后t1再收到5条消息(m16到m20)。我希望C1从m16开始强制开始读取,即从C1重新启动后收到的t1消息开始。由于提交的偏移量,它将从m6开始读取。我很好,C1在失败时会丢失信息。有没有办法为这个用例配置我的消费者。

apache-kafka kafka-consumer-api kafka-producer-api
1个回答
© www.soinside.com 2019 - 2024. All rights reserved.