Class KafkaUtil


  • public class KafkaUtil
    extends Object
    Author:
    Ales Justin
    • Constructor Detail

      • KafkaUtil

        public KafkaUtil()
    • Method Detail

      • result

        public static <T> T result​(org.apache.kafka.common.KafkaFuture<T> kf)
      • toCompletionStage

        public static <T> CompletionStage<T> toCompletionStage​(org.apache.kafka.common.KafkaFuture<T> kf)
      • createTopics

        public static void createTopics​(Properties properties,
                                        Set<String> topicNames,
                                        Map<String,​String> topicConfig)
        Create topics with sensible defaults.
        Parameters:
        properties - the Kafka properties to create Kafka admin
        topicNames - topics to create, if they don't exist
        topicConfig - the config to use for the new topic
      • createTopics

        public static void createTopics​(Properties properties,
                                        Set<String> topicNames)
      • createTopics

        public static void createTopics​(org.apache.kafka.clients.admin.Admin admin,
                                        Set<String> topicNames,
                                        Map<String,​String> topicConfig)
        Create topics with sensible defaults.
        Parameters:
        admin - the Kafka admin to use
        topicNames - topics to create, if they don't exist
        topicConfig - the config to use for the new topic
      • createTopics

        public static void createTopics​(org.apache.kafka.clients.admin.Admin admin,
                                        Set<String> topicNames)
      • createTopicsAsync

        public static CompletionStage<Void> createTopicsAsync​(org.apache.kafka.clients.admin.Admin admin,
                                                              Set<String> topicNames,
                                                              Map<String,​String> topicConfig)
        Create topics with sensible defaults, async.
        Parameters:
        admin - the Kafka admin to use
        topicNames - topics to create, if they don't exist