ReactiveKafkaAdminClient (SmallRye Reactive Messaging 3.12.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
```
@CheckReturnValue
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