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.