クラス TopicPartitionOffset

java.lang.ObjectSE
org.springframework.kafka.support.TopicPartitionOffset
public class TopicPartitionOffset extends ObjectSE
トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。オフセットは次のようになります。
  • null - 何もしない ;
  • 正（0 を含む）-isRelativeToCurrent() に応じて、パーティション内の絶対オフセット、またはこのコンシューマーの現在の位置に対するオフセットのいずれかを探します。
  • 負 - isRelativeToCurrent() に応じて、パーティション内の現在の最後のオフセットを基準にしたオフセット（consumer.seekToEnd() + initialOffset）またはこのコンシューマーの現在のオフセットを基準にしたオフセット（存在する場合）のいずれかを探します。
コンテナーが start()ed の場合、オフセットが適用されます。このクラスは、パーティションを手動で割り当てるとき、および遅延シーク操作に使用されます。
導入:
2.3
作成者:
Artem Bilan, Gary Russell, Soby Chacko

  • コンストラクターの詳細

    • TopicPartitionOffset

      public TopicPartitionOffset(StringSE topic, int partition)
      初期オフセット管理なしでインスタンスを構築します。
      パラメーター:
      topic - トピック。
      partition - パーティション。

    • TopicPartitionOffset

      public TopicPartitionOffset(@Nullable StringSE topic, int partition, @Nullable LongSE offset)
      isRelativeToCurrent() false で指定された初期オフセットを使用してインスタンスを構築します。
      パラメーター:
      topic - トピック。
      partition - パーティション。
      offset - オフセット。
      関連事項:

    • TopicPartitionOffset

      public TopicPartitionOffset(@Nullable StringSE topic, int partition, FunctionSE<LongSE,LongSE> offsetComputeFunction)
      オフセットを計算するために提供された関数を使用してインスタンスを構築します。
      パラメーター:
      topic - トピック。
      partition - パーティション。
      offsetComputeFunction - オフセットを計算する関数。
      導入:
      3.2.0

    • TopicPartitionOffset

      public TopicPartitionOffset(@Nullable StringSE topic, int partition, @Nullable LongSE offset, boolean relativeToCurrent)
      指定された初期オフセットを使用してインスタンスを構築します。
      パラメーター:
      topic - トピック。
      partition - パーティション。
      offset - 初期オフセット。
      relativeToCurrent - 初期オフセットが現在のコンシューマー位置に対して相対的である場合は true、正の初期オフセットが絶対的である場合は false、パーティションの現在の端に対して負のオフセット。

    • TopicPartitionOffset

      public TopicPartitionOffset(StringSE topic, int partition, TopicPartitionOffset.SeekPosition position)
      提供された TopicPartitionOffset.SeekPosition を使用してインスタンスを構築します。
      パラメーター:
      topic - トピック。
      partition - パーティション。
      position - TopicPartitionOffset.SeekPosition。

    • TopicPartitionOffset

      public TopicPartitionOffset(@Nullable StringSE topic, int partition, @Nullable LongSE offset, @Nullable TopicPartitionOffset.SeekPosition position)
      提供された TopicPartitionOffset.SeekPosition を使用してインスタンスを構築します。
      パラメーター:
      topic - トピック。
      partition - パーティション。
      offset - シーク位置からのオフセット（または TopicPartitionOffset.SeekPosition.TIMESTAMP のタイムスタンプ）。
      position - TopicPartitionOffset.SeekPosition。
      導入:
      2.3

    • TopicPartitionOffset

      public TopicPartitionOffset(org.apache.kafka.common.TopicPartition topicPartition, @Nullable LongSE offset, @Nullable TopicPartitionOffset.SeekPosition position)
      提供された TopicPartitionOffset.SeekPosition を使用してインスタンスを構築します。
      パラメーター:
      topicPartition - トピック / パーティション。
      offset - シーク位置からのオフセット（または TopicPartitionOffset.SeekPosition.TIMESTAMP のタイムスタンプ）。
      position - TopicPartitionOffset.SeekPosition。
      導入:
      2.3

  • メソッドの詳細

    • getTopicPartition

      public org.apache.kafka.common.TopicPartition getTopicPartition()

    • getPartition

      public int getPartition()

    • getTopic

      public StringSE getTopic()

    • getOffset

      public @Nullable LongSE getOffset()

    • setOffset

      public void setOffset(LongSE offset)
      オフセットを設定します。
      パラメーター:
      offset - オフセット。
      導入:
      2.5.5

    • isRelativeToCurrent

      public boolean isRelativeToCurrent()

    • setRelativeToCurrent

      public void setRelativeToCurrent(boolean relativeToCurrent)
      オフセットが現在の位置を基準にしているかどうかを設定します。
      パラメーター:
      relativeToCurrent - カレントに対して真。
      導入:
      2.5.5

    • getPosition

      public @Nullable TopicPartitionOffset.SeekPosition getPosition()

    • getOffsetComputeFunction

      public @Nullable FunctionSE<LongSE,LongSE> getOffsetComputeFunction()

    • equals

      public boolean equals(ObjectSE o)
      オーバーライド:
      クラス ObjectSE の equalsSE 

    • hashCode

      public int hashCode()
      オーバーライド:
      クラス ObjectSE の hashCode 

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString