アノテーションインターフェース TopicPartition
トピック / パーティション情報を
KafkaListener
に追加するために使用されます。- 作成者:
- Gary Russell, Artem Bilan
必須定数のサマリー
必須要素オプション要素のサマリー
オプション要素
要素の詳細
topic
StringSE topic耳を傾けるトピック。- 戻り値:
- 聞くトピック。プロパティプレースホルダーと SpEL 式がサポートされており、文字列に解決する必要があります。
partitions
StringSE[] partitionsトピック内のパーティション。ここで指定したパーティションはpartitionOffsets()
で複製できません。各文字列には、カンマ区切りのパーティションのリスト、またはパーティションの範囲 (例:0-5, 7, 10-15
) を含めることができます。- 戻り値:
- トピック内のパーティション。プロパティプレースホルダーと SpEL 式がサポートされており、整数(または整数として解析できる文字列)に解決する必要があります。
- デフォルト:
- {}
partitionOffsets
PartitionOffset[] partitionOffsetsトピック内の初期オフセットを持つパーティション。'partition' プロパティが '*' の場合、PartitionOffset
のインスタンスは 1 つだけでなければなりません。ここで指定されたパーティションは、partitions()
で複製できません。- 戻り値:
PartitionOffset
配列。
- デフォルト:
- {}