Package io.apicurio.registry.utils.kafka
Class KafkaUtil
- java.lang.Object
-
- io.apicurio.registry.utils.kafka.KafkaUtil
-
public class KafkaUtil extends Object
- Author:
- Ales Justin
-
-
Constructor Summary
Constructors Constructor Description KafkaUtil()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
createTopics(Properties properties, Set<String> topicNames)
static void
createTopics(Properties properties, Set<String> topicNames, Map<String,String> topicConfig)
Create topics with sensible defaults.static void
createTopics(org.apache.kafka.clients.admin.Admin admin, Set<String> topicNames)
static void
createTopics(org.apache.kafka.clients.admin.Admin admin, Set<String> topicNames, Map<String,String> topicConfig)
Create topics with sensible defaults.static CompletionStage<Void>
createTopicsAsync(org.apache.kafka.clients.admin.Admin admin, Set<String> topicNames, Map<String,String> topicConfig)
Create topics with sensible defaults, async.static <T> T
result(org.apache.kafka.common.KafkaFuture<T> kf)
static <T> CompletionStage<T>
toCompletionStage(org.apache.kafka.common.KafkaFuture<T> kf)
-
-
-
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 admintopicNames
- topics to create, if they don't existtopicConfig
- 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 usetopicNames
- topics to create, if they don't existtopicConfig
- 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 usetopicNames
- topics to create, if they don't exist
-
-