パッケージ org.springframework.kafka.config

クラス TopicBuilder

java.lang.ObjectSE
org.springframework.kafka.config.TopicBuilder
public final class TopicBuilder extends ObjectSE
NewTopic のビルダー。2.6 パーティションとレプリカのデフォルトは Optional.empty() であるため、ブローカーのデフォルトが適用されることを示します。
導入:
2.3
作成者:
Gary Russell, Sanghyeok An

  • メソッドの詳細

    • partitions

      public TopicBuilder partitions(int partitionCount)
      パーティションの数を設定します（デフォルトのブローカー 'num.partitions' ）。
      パラメーター:
      partitionCount - パーティション。
      戻り値:
      ビルダー。

    • replicas

      public TopicBuilder replicas(int replicaCount)
      レプリカの数を設定します（デフォルトブローカー 'default.replication.factor' ）。
      パラメーター:
      replicaCount - レプリカ（ショートにキャストされます）。
      戻り値:
      ビルダー。

    • replicasAssignments

      public TopicBuilder replicasAssignments(MapSE<IntegerSE,ListSE<IntegerSE>> replicaAssignments)
      レプリカの割り当てを設定します。
      パラメーター:
      replicaAssignments - 割り当て。
      戻り値:
      ビルダー。
      関連事項:
      • NewTopic.replicasAssignments()

    • assignReplicas

      public TopicBuilder assignReplicas(int partition, ListSE<IntegerSE> replicaList)
      個別のレプリカ割り当てを追加します。
      パラメーター:
      partition - パーティション。
      replicaList - レプリカ。
      戻り値:
      ビルダー。
      関連事項:
      • NewTopic.replicasAssignments()

    • configs

      public TopicBuilder configs(MapSE<StringSE,StringSE> configProps)
      構成を設定します。
      パラメーター:
      configProps - 構成。
      戻り値:
      ビルダー。
      関連事項:
      • NewTopic.configs()

    • config

      public TopicBuilder config(StringSE configName, StringSE configValue)
      構成オプションを設定します。
      パラメーター:
      configName - 名前。
      configValue - 値。
      戻り値:
      ビルダー
      関連事項:
      • TopicConfig

    • compact

      public TopicBuilder compact()
      TopicConfig.CLEANUP_POLICY_CONFIG を TopicConfig.CLEANUP_POLICY_COMPACT に設定します。
      戻り値:
      ビルダー。

    • build

      public org.apache.kafka.clients.admin.NewTopic build()

    • name

      public static TopicBuilder name(StringSE name)
      指定された名前で TopicBuilder を作成します。
      パラメーター:
      name - 名前。
      戻り値:
      ビルダー。