对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.0！spring-doc.cn

Topic/Partition 初始偏移量

有几种方法可以设置分区的初始偏移量。spring-doc.cn

手动分配分区时，您可以在配置的参数中设置初始偏移量（如果需要）（请参阅 消息侦听器容器）。 您也可以随时寻找特定的偏移量。TopicPartitionOffsetspring-doc.cn

当您在 broker 分配分区的位置使用组管理时：spring-doc.cn

  • 对于新的 ，初始偏移量由消费者属性 （ 或 ） 确定。group.idauto.offset.resetearliestlatestspring-doc.cn

  • 对于现有组 ID，初始偏移量是该组 ID 的当前偏移量。 但是，您可以在初始化期间（或之后的任何时间）寻找特定的偏移量。spring-doc.cn