public final class SbkTopicUtils extends Object
Modifier and Type | Class and Description |
---|---|
static class |
SbkTopicUtils.SbkTopicConfig |
static class |
SbkTopicUtils.SbkTopicConfigBuilder |
Constructor and Description |
---|
SbkTopicUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
checkTopicPropertiesMaybeCreate(SbkTopicUtils.SbkTopicConfig topicConfig,
Map<String,?> config)
Checks for existence of a topic and creates it if its not already present.
|
static void |
deleteTopics(org.apache.kafka.clients.admin.ConfluentAdmin adminClient,
Set<String> allTopics,
List<String> topics)
Delete the topics to be deleted after verifying their existence.
|
public static boolean checkTopicPropertiesMaybeCreate(SbkTopicUtils.SbkTopicConfig topicConfig, Map<String,?> config)
public static void deleteTopics(org.apache.kafka.clients.admin.ConfluentAdmin adminClient, Set<String> allTopics, List<String> topics)
adminClient
- -- for topic delete operationallTopics
- -- all topics in the cluster to check if topics to be deleted existtopics
- -- topics to be deleted