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

Class KafkaAdminClientImpl

java.lang.Object

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

All Implemented Interfaces:

KafkaAdminClient

public class KafkaAdminClientImpl
extends java.lang.Object
implements KafkaAdminClient

Constructor Summary

Constructors

Constructor and Description
KafkaAdminClientImpl(java.lang.String bootstrapServers)

Method Summary

Modifier and Type	Method and Description
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.bluemind.central.reverse.proxy.model.common.kafka.KafkaAdminClient

create

Constructor Detail

KafkaAdminClientImpl

public KafkaAdminClientImpl(java.lang.String bootstrapServers)

Method Detail

listTopics

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

Specified by:

listTopics in interface KafkaAdminClient

describeTopics

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

Specified by:

describeTopics in interface KafkaAdminClient

describeConsumerGroups

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

Specified by:

describeConsumerGroups in interface KafkaAdminClient

deleteConsumerGroupOffsets

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

Specified by:

deleteConsumerGroupOffsets in interface KafkaAdminClient

listConsumerGroups

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

Specified by:

listConsumerGroups in interface KafkaAdminClient

deleteConsumerGroups

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

Specified by:

deleteConsumerGroups in interface KafkaAdminClient

resetTopicOffset

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

Specified by:

resetTopicOffset in interface KafkaAdminClient

createTopic

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

Specified by:

createTopic in interface KafkaAdminClient