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


@TargetSE({}) @RetentionSE(RUNTIMESE) public @interface 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 配列。
      デフォルト:
      {}