此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.9spring-doc.cadn.net.cn

主题/分区初始偏移量

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

手动分配分区时,您可以在配置的TopicPartitionOffset参数(参见消息侦听器容器)。 您还可以随时查找特定的偏移量。spring-doc.cadn.net.cn

当您使用组管理时,代理分配分区:spring-doc.cadn.net.cn

  • 对于新的group.id,则初始偏移量由auto.offset.reset消费者属性 (earliestlatest).spring-doc.cadn.net.cn

  • 对于现有组 ID,初始偏移量是该组 ID 的当前偏移量。 但是,可以在初始化期间(或之后的任何时间)查找特定偏移量。spring-doc.cadn.net.cn