io.smallrye.reactive.messaging.kafka.impl

Class ReactiveKafkaAdminClient

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.ReactiveKafkaAdminClient

All Implemented Interfaces:

KafkaAdmin

public class ReactiveKafkaAdminClient
extends Object
implements KafkaAdmin

Constructor Summary

Constructors

Constructor and Description
ReactiveKafkaAdminClient(Map<String,String> config)

Method Summary

Modifier and Type	Method and Description
void	closeAndAwait()
io.smallrye.mutiny.Uni<Set<String>>	listTopics()
org.apache.kafka.clients.admin.Admin	unwrap()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveKafkaAdminClient

public ReactiveKafkaAdminClient(Map<String,String> config)

Method Detail

listTopics

public io.smallrye.mutiny.Uni<Set<String>> listTopics()

Specified by:

listTopics in interface KafkaAdmin

unwrap

public org.apache.kafka.clients.admin.Admin unwrap()

Specified by:

unwrap in interface KafkaAdmin

closeAndAwait

public void closeAndAwait()

Specified by:

closeAndAwait in interface KafkaAdmin