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

Question

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

Answer 1

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