|
对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.0！ |
Topic/Partition 初始偏移量
有几种方法可以设置分区的初始偏移量。
手动分配分区时，您可以在配置的TopicPartitionOffset参数（请参阅 消息侦听器容器）。
您也可以随时寻找特定的偏移量。
当您在 broker 分配分区的位置使用组管理时：
-
对于新的
group.id，则初始偏移量由auto.offset.resetConsumer 属性 （earliest或latest). -
对于现有组 ID，初始偏移量是该组 ID 的当前偏移量。 但是，您可以在初始化期间（或之后的任何时间）寻找特定的偏移量。