io.smallrye.reactive.messaging.kafka

Interface KafkaClientService

All Known Implementing Classes:

KafkaClientServiceImpl

@Experimental(value="experimental api")
public interface KafkaClientService

Method Summary

Modifier and Type	Method and Description
<K,V> KafkaConsumer<K,V>	getConsumer(String channel) Gets the managed Kafka Consumer for the given channel.
<K,V> org.apache.kafka.clients.producer.Producer<K,V>	getProducer(String channel) Gets the managed Kafka Producer for the given channel.

Method Detail

getConsumer

<K,V> KafkaConsumer<K,V> getConsumer(String channel)

Gets the managed Kafka Consumer for the given channel. This method returns the reactive consumer.

Be aware that most actions requires to be run on the Kafka polling thread. You can schedule actions using:

getConsumer(channel).runOnPollingThread(c -> { ... })

You can retrieve the low-level client using the KafkaConsumer.unwrap() method.

Type Parameters:

K - the type of the key

V - the type of the value

Parameters:

channel - the channel, must not be null

Returns:

the consumer, null if not found

getProducer

<K,V> org.apache.kafka.clients.producer.Producer<K,V> getProducer(String channel)

Gets the managed Kafka Producer for the given channel.

Type Parameters:

K - the type of the key

V - the type of the value

Parameters:

channel - the channel, must not be null

Returns:

the producer, null if not found