在Kafka中将确认设置为false时,我希望消息不会从主题中删除。我该怎么做?
vd2z7a6w1#
消息一旦被消费,就不会从Kafka主题中删除;Kafka不是这样工作的。kafka只跟踪日志中某个特定消费者读取到的偏移量。如果您想重新使用消息,那么您的消费者只需从日志中所需的偏移量请求消息。
1条答案
按热度按时间vd2z7a6w1#
消息一旦被消费,就不会从Kafka主题中删除;Kafka不是这样工作的。kafka只跟踪日志中某个特定消费者读取到的偏移量。
如果您想重新使用消息,那么您的消费者只需从日志中所需的偏移量请求消息。