net.bluemind.central.reverse.proxy.model.common.kafka

Interface KafkaAdminClient

All Known Implementing Classes:

KafkaAdminClientImpl

public interface KafkaAdminClient

Method Summary

Modifier and Type	Method and Description
static KafkaAdminClient	create(java.lang.String bootstrapServers)
io.vertx.core.Future<org.apache.kafka.common.Uuid>	createTopic(org.apache.kafka.clients.admin.NewTopic newTopic, org.apache.kafka.clients.admin.CreateTopicsOptions options)
io.vertx.core.Future<java.lang.Void>	deleteConsumerGroupOffsets(java.lang.String groupId, java.util.Set<org.apache.kafka.common.TopicPartition> topicPartitions)
io.vertx.core.Future<java.util.Collection<org.apache.kafka.clients.admin.ConsumerGroupListing>>	deleteConsumerGroups(java.util.Collection<java.lang.String> groupIds)
io.vertx.core.Future<java.util.Map<java.lang.String,org.apache.kafka.clients.admin.ConsumerGroupDescription>>	describeConsumerGroups(java.util.Collection<java.lang.String> names)
io.vertx.core.Future<java.util.Map<java.lang.String,org.apache.kafka.clients.admin.TopicDescription>>	describeTopics(java.util.Collection<java.lang.String> topicNames)
io.vertx.core.Future<java.util.Collection<org.apache.kafka.clients.admin.ConsumerGroupListing>>	listConsumerGroups()
io.vertx.core.Future<java.util.Set<java.lang.String>>	listTopics()
io.vertx.core.Future<java.lang.Void>	resetTopicOffset(java.lang.String consumerGroupToBeReset, java.util.Collection<java.lang.String> topicNames)

Method Detail

create

static KafkaAdminClient create(java.lang.String bootstrapServers)

listTopics

io.vertx.core.Future<java.util.Set<java.lang.String>> listTopics()

describeTopics

io.vertx.core.Future<java.util.Map<java.lang.String,org.apache.kafka.clients.admin.TopicDescription>> describeTopics(java.util.Collection<java.lang.String> topicNames)

listConsumerGroups

io.vertx.core.Future<java.util.Collection<org.apache.kafka.clients.admin.ConsumerGroupListing>> listConsumerGroups()

describeConsumerGroups

io.vertx.core.Future<java.util.Map<java.lang.String,org.apache.kafka.clients.admin.ConsumerGroupDescription>> describeConsumerGroups(java.util.Collection<java.lang.String> names)

deleteConsumerGroupOffsets

io.vertx.core.Future<java.lang.Void> deleteConsumerGroupOffsets(java.lang.String groupId,
                                                                java.util.Set<org.apache.kafka.common.TopicPartition> topicPartitions)

deleteConsumerGroups

io.vertx.core.Future<java.util.Collection<org.apache.kafka.clients.admin.ConsumerGroupListing>> deleteConsumerGroups(java.util.Collection<java.lang.String> groupIds)

resetTopicOffset

io.vertx.core.Future<java.lang.Void> resetTopicOffset(java.lang.String consumerGroupToBeReset,
                                                      java.util.Collection<java.lang.String> topicNames)

createTopic

io.vertx.core.Future<org.apache.kafka.common.Uuid> createTopic(org.apache.kafka.clients.admin.NewTopic newTopic,
                                                               org.apache.kafka.clients.admin.CreateTopicsOptions options)