|
对于最新稳定版本,请使用Spring for Apache Kafka 4.0.4! |
主题/分区初始偏移
有几种方式可以设置分区的初始偏移。
当手动分配分区时,您可以在配置的TopicPartitionOffset参数中设置初始偏移(如果需要;参见消息监听容器)。
您也可以在任何时候跳转到特定偏移。
当您使用其中经纪人分配分区的组管理时:
-
对于一个新的
group.id,初始偏移由auto.offset.reset消费者属性(earliest或latest)确定。 -
对于现有的组ID,初始偏移量是该组ID的当前偏移量。 但是,您可以在初始化时(或之后任何时候)跳转到特定的偏移量。