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

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void createOrModifyTopics​(org.apache.kafka.clients.admin.NewTopic... topics)
      Create topics if they don't exist or increase the number of partitions if needed.
      java.util.Map<java.lang.String,​org.apache.kafka.clients.admin.TopicDescription> describeTopics​(java.lang.String... topicNames)
      Obtain TopicDescriptions for these topics.
      java.util.Map<java.lang.String,​java.lang.Object> getConfigurationProperties()
      Get an unmodifiable copy of this admin's configuration.

    • Method Detail

      • getConfigurationProperties

        java.util.Map<java.lang.String,​java.lang.Object> 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

        java.util.Map<java.lang.String,​org.apache.kafka.clients.admin.TopicDescription> describeTopics​(java.lang.String... topicNames)
        Obtain TopicDescriptions for these topics.
        Parameters:
        topicNames - the topic names.
        Returns:
        a map of name:topicDescription.