Package 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 Detail

      • listTopics

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

      • unwrap

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

      • closeAndAwait

        void closeAndAwait()