インターフェース KafkaAdminOperations
- すべての既知の実装クラス:
KafkaAdmin
public interface KafkaAdminOperations
AdminClient
をラップする多くの便利なメソッドを提供します。- 導入:
- 2.7
- 作成者:
- Gary Russell
メソッドのサマリー
修飾子と型メソッド説明利用可能な場合は、クラスター ID を返します。void
createOrModifyTopics
(org.apache.kafka.clients.admin.NewTopic... topics) トピックが存在しない場合は作成するか、必要に応じてパーティションの数を増やします。describeTopics
(StringSE... topicNames) これらのトピックのTopicDescription
を取得します。この管理者の構成の変更不可能なコピーを取得します。
メソッドの詳細
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
- トピック名。- 戻り値:
- name:topicDescription のマップ。
clusterId
利用可能な場合は、クラスター ID を返します。- 戻り値:
- 記述クラスタ ID。
- 導入:
- 3.0