ReactiveKafkaAdminClient (SmallRye Reactive Messaging 3.10.1 API)

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 Description

ReactiveKafkaAdminClient(Map<String,String> config)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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