我正在考虑使用ApacheKafka作为事件存储来存储微服务中的事件。我通过各种博客读到的一件事是，Kafka可以被认为是真理的唯一来源，Kafka日志将存储给定主题的所有事件。我想知道Kafka是否有能力重播消息，因为时间的开始（以防发生硬盘/网络崩溃为例）？（注意，我看到一些日志存储在主题目录下的/tmp文件夹中）。是否有人知道可以调用任何命令（如果有的话）来重播主题中的消息？
aydmsdu91#
是的，你可以重播消息。因为消费者可以控制重置偏移量。您可以从头开始读取消息，或者如果知道任何现有的偏移量值，也可以从那里读取。一旦消息被提交，它将一直在主题中，直到它的保留期结束。默认保留期为7天，但您可以随时更改。
scyqe7ek2#
是的，你可以寻找一个特定的偏移量，但是时间的开始取决于主题或代理配置。iirc，默认保留期为7天。请参阅Kafka文档。
2条答案
按热度按时间aydmsdu91#
是的，你可以重播消息。因为消费者可以控制重置偏移量。您可以从头开始读取消息，或者如果知道任何现有的偏移量值，也可以从那里读取。一旦消息被提交，它将一直在主题中，直到它的保留期结束。默认保留期为7天，但您可以随时更改。
scyqe7ek2#
是的，你可以寻找一个特定的偏移量，但是
时间的开始
取决于主题或代理配置。iirc，默认保留期为7天。
请参阅Kafka文档。