清理分区后，Kafka是否将偏移量更改为0

Question

假设Kafka在1000个事件后清理我们的分区。我想通过在Consumer中使用查找功能来设置特定的偏移量。如果Kafka在1000条消息后清理分区，我是否需要在seek方法中将开始偏移量设置为1000或0？

Answer 1

否，消息的偏移量永远不会改变。它是日志中某个位置的永久标识符。清除后的新消息将具有偏移量1000。