アノテーションインターフェース PartitionOffset

要素の詳細

• partition

  StringSE partition

  リッスンするトピック内のパーティション。プロパティプレースホルダーと SpEL 式がサポートされており、これらは Integer (または Integer として解析できる String) に解決される必要があります。"*" は、初期オフセットが周囲の TopicPartition 内のすべてのパーティションに適用されることを示します。文字列には、カンマで区切られたパーティションのリストまたはパーティションの範囲 (例: 0-5, 7, 10-15) を含めることができます。この場合、オフセットはすべてのパーティションに適用されます。それらのパーティションの。

  戻り値:

  トピック内のパーティション。

• initialOffset

  StringSE initialOffset

  partition() の初期オフセット。プロパティプレースホルダーと SpEL 式がサポートされており、Long（または Long として解析できる文字列）に解決する必要があります。

  戻り値:

  初期オフセット。

• relativeToCurrent

  StringSE relativeToCurrent

  デフォルトでは、正の initialOffset() は絶対値であり、負の値は現在のトピックの終わりを基準にしています。これが "true" の場合、初期オフセット（正または負）は現在のコンシューマーの位置を基準にしています。

  戻り値:

  オフセットが現在の位置を基準にしているかどうか。

  導入:

  1.1

  デフォルト:

  「偽」

• seekPosition

  StringSE seekPosition

  パーティション割り当て時にシークする位置。デフォルトでは、オフセットでシークします。TopicPartitionOffset.SeekPosition シーク位置列挙名を設定して、「特別な」シークを指定します。大文字と小文字の制限はありません。seekPosition が 'BEGINNING' または 'END' に設定されている場合、relativeToCurrent と initialOffset は無視されます。seekPosition が 'TIMESTAMP' に設定されている場合、initialOffset はタイムスタンプを意味し、relativeToCurrent は無視されます。

  戻り値:

  特別なシーク。

  導入:

  3.2

  関連事項:

  • TopicPartitionOffset.SeekPosition

  デフォルト:

  ""