io.smallrye.reactive.messaging.kafka

Interface KafkaAdmin

All Known Implementing Classes:

ReactiveKafkaAdminClient

public interface KafkaAdmin

Internal interface for Kafka admin client. To complete with remaining Admin method wrappers, if decided to expose it externally.

Method Summary

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

Method Detail

listTopics

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

unwrap

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

closeAndAwait

void closeAndAwait()