クラス TopicPartitionOffset
java.lang.ObjectSE
org.springframework.kafka.support.TopicPartitionOffset
トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。オフセットは次のようになります。
null
- 何もしない ;- 正(
0
を含む)-isRelativeToCurrent()
に応じて、パーティション内の絶対オフセット、またはこのコンシューマーの現在の位置に対するオフセットのいずれかを探します。 - 負 -
isRelativeToCurrent()
に応じて、パーティション内の現在の最後のオフセットを基準にしたオフセット(consumer.seekToEnd() + initialOffset
)またはこのコンシューマーの現在のオフセットを基準にしたオフセット(存在する場合)のいずれかを探します。
start()
ed の場合、オフセットが適用されます。このクラスは、パーティションを手動で割り当てるとき、および遅延シーク操作に使用されます。- 導入:
- 2.3
- 作成者:
- Artem Bilan, Gary Russell, Soby Chacko
ネストされたクラスのサマリー
ネストされたクラスコンストラクターのサマリー
コンストラクターコンストラクター説明TopicPartitionOffset
(StringSE topic, int partition) 初期オフセット管理なしでインスタンスを構築します。TopicPartitionOffset
(StringSE topic, int partition, LongSE offset) isRelativeToCurrent()
false で指定された初期オフセットを使用してインスタンスを構築します。TopicPartitionOffset
(StringSE topic, int partition, LongSE offset, boolean relativeToCurrent) 指定された初期オフセットを使用してインスタンスを構築します。TopicPartitionOffset
(StringSE topic, int partition, LongSE offset, TopicPartitionOffset.SeekPosition position) 提供されたTopicPartitionOffset.SeekPosition
を使用してインスタンスを構築します。TopicPartitionOffset
(StringSE topic, int partition, FunctionSE<LongSE, LongSE> offsetComputeFunction) オフセットを計算するために提供された関数を使用してインスタンスを構築します。TopicPartitionOffset
(StringSE topic, int partition, TopicPartitionOffset.SeekPosition position) 提供されたTopicPartitionOffset.SeekPosition
を使用してインスタンスを構築します。TopicPartitionOffset
(org.apache.kafka.common.TopicPartition topicPartition, LongSE offset, TopicPartitionOffset.SeekPosition position) 提供されたTopicPartitionOffset.SeekPosition
を使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明boolean
int
getTopic()
org.apache.kafka.common.TopicPartition
int
hashCode()
boolean
void
オフセットを設定します。void
setRelativeToCurrent
(boolean relativeToCurrent) オフセットが現在の位置を基準にしているかどうかを設定します。toString()
コンストラクターの詳細
TopicPartitionOffset
初期オフセット管理なしでインスタンスを構築します。- パラメーター:
topic
- トピック。partition
- パーティション。
TopicPartitionOffset
isRelativeToCurrent()
false で指定された初期オフセットを使用してインスタンスを構築します。- パラメーター:
topic
- トピック。partition
- パーティション。offset
- オフセット。- 関連事項:
TopicPartitionOffset
public TopicPartitionOffset(StringSE topic, int partition, FunctionSE<LongSE, LongSE> offsetComputeFunction) オフセットを計算するために提供された関数を使用してインスタンスを構築します。- パラメーター:
topic
- トピック。partition
- パーティション。offsetComputeFunction
- オフセットを計算する関数。- 導入:
- 3.2.0
TopicPartitionOffset
public TopicPartitionOffset(StringSE topic, int partition, 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(StringSE topic, int partition, 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, 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
getOffset
setOffset
オフセットを設定します。- パラメーター:
offset
- オフセット。- 導入:
- 2.5.5
isRelativeToCurrent
public boolean isRelativeToCurrent()setRelativeToCurrent
public void setRelativeToCurrent(boolean relativeToCurrent) オフセットが現在の位置を基準にしているかどうかを設定します。- パラメーター:
relativeToCurrent
- カレントに対して真。- 導入:
- 2.5.5
getPosition
getOffsetComputeFunction
equals
hashCode
public int hashCode()toString