Package org.springframework.kafka.core
Interface KafkaAdminOperations
- All Known Implementing Classes:
KafkaAdmin
public interface KafkaAdminOperations
Provides a number of convenience methods wrapping
AdminClient
.- Since:
- 2.7
- Author:
- Gary Russell
-
Method Summary
Modifier and TypeMethodDescriptionReturn the cluster id, if available.void
createOrModifyTopics
(org.apache.kafka.clients.admin.NewTopic... topics) Create topics if they don't exist or increase the number of partitions if needed.describeTopics
(String... topicNames) ObtainTopicDescription
s for these topics.Get an unmodifiable copy of this admin's configuration.
-
Method Details
-
getConfigurationProperties
Get an unmodifiable copy of this admin's configuration.- Returns:
- the configuration map.
-
createOrModifyTopics
void createOrModifyTopics(org.apache.kafka.clients.admin.NewTopic... topics) Create topics if they don't exist or increase the number of partitions if needed.- Parameters:
topics
- the topics.
-
describeTopics
ObtainTopicDescription
s for these topics.- Parameters:
topicNames
- the topic names.- Returns:
- a map of name:topicDescription.
-
clusterId
Return the cluster id, if available.- Returns:
- the describe cluster id.
- Since:
- 3.0
-