インターフェース KafkaAdminOperations

すべての既知の実装クラス:
KafkaAdmin
public interface KafkaAdminOperations
AdminClient をラップする多くの便利なメソッドを提供します。
導入:
2.7
作成者:
Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    @Nullable StringSE
    clusterId()
    利用可能な場合は、クラスター ID を返します。
    void
    createOrModifyTopics(org.apache.kafka.clients.admin.NewTopic... topics)
    トピックが存在しない場合は作成するか、必要に応じてパーティションの数を増やします。
    void
    deleteTopics(StringSE... topicNames)
    Kafka クラスターからトピックを削除します。
    MapSE<StringSE, org.apache.kafka.clients.admin.TopicDescription>
    describeTopics(StringSE... topicNames)
    これらのトピックの TopicDescription を取得します。
    MapSE<StringSE,ObjectSE>
    getConfigurationProperties()
    この管理者の構成の変更不可能なコピーを取得します。

  • メソッドの詳細

    • getConfigurationProperties

      MapSE<StringSE,ObjectSE> getConfigurationProperties()
      この管理者の構成の変更不可能なコピーを取得します。
      戻り値:
      構成マップ。

    • createOrModifyTopics

      void createOrModifyTopics(org.apache.kafka.clients.admin.NewTopic... topics)
      トピックが存在しない場合は作成するか、必要に応じてパーティションの数を増やします。
      パラメーター:
      topics - トピック。

    • describeTopics

      MapSE<StringSE, org.apache.kafka.clients.admin.TopicDescription> describeTopics(StringSE... topicNames)
      これらのトピックの TopicDescription を取得します。
      パラメーター:
      topicNames - トピック名。
      戻り値:
      名前: topicDescription の地図。

    • deleteTopics

      void deleteTopics(StringSE... topicNames)
      Kafka クラスターからトピックを削除します。
      パラメーター:
      topicNames - 削除するトピック名。
      導入:
      4.0

    • clusterId

      @Nullable StringSE clusterId()
      利用可能な場合は、クラスター ID を返します。
      戻り値:
      記述クラスタ ID。
      導入:
      3.0