| Package | Description |
|---|---|
| io.smallrye.reactive.messaging.kafka | |
| io.smallrye.reactive.messaging.kafka.impl |
| Modifier and Type | Method and Description |
|---|---|
<K,V> KafkaProducer<K,V> |
KafkaClientService.getProducer(String channel)
Gets the managed Kafka Producer for the given channel.
|
<K,V> KafkaProducer<K,V> |
KafkaConnector.getProducer(String channel) |
| Modifier and Type | Class and Description |
|---|---|
class |
ReactiveKafkaProducer<K,V> |
| Modifier and Type | Method and Description |
|---|---|
KafkaProducer<?,?> |
KafkaSink.getProducer() |
<K,V> KafkaProducer<K,V> |
KafkaClientServiceImpl.getProducer(String channel) |
Copyright © 2018–2021 SmallRye. All rights reserved.