此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.9! |
主题/分区初始偏移量
有几种方法可以设置分区的初始偏移量。
手动分配分区时,您可以在配置的TopicPartitionOffset
参数(参见消息侦听器容器)。
您还可以随时查找特定的偏移量。
当您使用组管理时,代理分配分区:
-
对于新的
group.id
,则初始偏移量由auto.offset.reset
消费者属性 (earliest
或latest
). -
对于现有组 ID,初始偏移量是该组 ID 的当前偏移量。 但是,可以在初始化期间(或之后的任何时间)查找特定偏移量。