Topic/Partition 初始偏移量
有几种方法可以设置分区的初始偏移量。
手动分配分区时,您可以在配置的TopicPartitionOffset
参数(请参阅 消息侦听器容器)。
您也可以随时寻找特定的偏移量。
当您在 broker 分配分区的位置使用组管理时:
-
对于新的
group.id
,则初始偏移量由auto.offset.reset
Consumer 属性 (earliest
或latest
). -
对于现有组 ID,初始偏移量是该组 ID 的当前偏移量。 但是,您可以在初始化期间(或之后的任何时间)寻找特定的偏移量。