Kafka通過消費者組、消費者位移和分區分配等機制確保消息被消費一次且只有一個消費者消費，同時通過位移提交實現消息回溯。以下是具體的回溯方法：
在Kafka中，每條消息都有一個唯一的偏移量（offset），用來表示消息在分區中的位置。消費者每次消費了消息，都會把消費的此條消息的偏移量提交到broker（消息節點），用于記錄消費到分區中的位置，下條消息從這個位置之后開始消費。所以基于消息偏移量回溯很簡單，只需要重置偏移量，然后消費者會從該偏移量之后開始消費。
要想講清楚Kafka基于時間點的消息回溯的原理，得先從Kafka存儲消息的文件格式開始講。Kafka存儲消息是以日志的形式存儲的，每一個分區都對應一個日志，但是日志不是一個文件，是多個文件組成的。日志文件都存儲在一個文件夾里面的，文件格式為：topic-0。文件夾里面存儲的是什么文件呢，日志分段文件、偏移量索引文件、時間戳索引文件。
一旦你有了所需時間點的偏移量，就可以使用kafka-consumer-groups.sh腳本來重置消費者組的偏移量。例如，如果你知道在特定分區中，你需要將偏移量重置為12345，你可以使用以下命令：
./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --to-offset 12345 --group my-consumer-group --topic my-topic --partition 0 --execute
通過上述方法，Kafka能夠有效地支持消息的回溯，確保在需要時能夠重新處理消息。
