最新の安定バージョンについては、Spring for Apache Kafka 4.0.0 を使用してください！

トピック / パーティションの初期オフセット

パーティションの初期オフセットを設定するには、いくつかの方法があります。

パーティションを手動で割り当てる場合、構成済みの TopicPartitionOffset 引数に初期オフセットを設定できます (必要に応じて) ( メッセージリスナコンテナーを参照)。いつでも特定のオフセットにシークすることもできます。

ブローカーがパーティションを割り当てるグループ管理を使用する場合:

  • 新しい group.id の場合、初期オフセットは auto.offset.reset コンシューマープロパティ (earliest または latest) によって決定されます。

  • 既存のグループ ID の場合、初期オフセットはそのグループ ID の現在のオフセットです。ただし、初期化中 (またはその後のいつでも) に特定のオフセットをシークできます。