io.smallrye.reactive.messaging.kafka.impl

Class KafkaSource<K,V>

java.lang.Object

io.smallrye.reactive.messaging.kafka.impl.KafkaSource<K,V>

public class KafkaSource<K,V>
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSource(io.vertx.mutiny.core.Vertx vertx, String consumerGroup, KafkaConnectorIncomingConfiguration config, javax.enterprise.inject.Instance<KafkaConsumerRebalanceListener> consumerRebalanceListeners, KafkaCDIEvents kafkaCDIEvents, javax.enterprise.inject.Instance<DeserializationFailureHandler<?>> deserializationFailureHandlers, int index)

Method Summary

Modifier and Type	Method and Description
void	closeQuietly()
String	getChannel()
KafkaCommitHandler	getCommitHandler()
ReactiveKafkaConsumer<K,V>	getConsumer() For testing purpose only
io.smallrye.mutiny.Multi<IncomingKafkaRecord<K,V>>	getStream()
boolean	hasSubscribers()
void	incomingTrace(IncomingKafkaRecord<K,V> kafkaRecord)
void	isAlive(HealthReport.HealthReportBuilder builder)
void	isReady(HealthReport.HealthReportBuilder builder)
void	reportFailure(Throwable failure, boolean fatal)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaSource

public KafkaSource(io.vertx.mutiny.core.Vertx vertx,
                   String consumerGroup,
                   KafkaConnectorIncomingConfiguration config,
                   javax.enterprise.inject.Instance<KafkaConsumerRebalanceListener> consumerRebalanceListeners,
                   KafkaCDIEvents kafkaCDIEvents,
                   javax.enterprise.inject.Instance<DeserializationFailureHandler<?>> deserializationFailureHandlers,
                   int index)

Method Detail

reportFailure

public void reportFailure(Throwable failure,
                          boolean fatal)

incomingTrace

public void incomingTrace(IncomingKafkaRecord<K,V> kafkaRecord)

getStream

public io.smallrye.mutiny.Multi<IncomingKafkaRecord<K,V>> getStream()

closeQuietly

public void closeQuietly()

isAlive

public void isAlive(HealthReport.HealthReportBuilder builder)

isReady

public void isReady(HealthReport.HealthReportBuilder builder)

getConsumer

public ReactiveKafkaConsumer<K,V> getConsumer()

For testing purpose only

Returns:

get the underlying consumer.

getCommitHandler

public KafkaCommitHandler getCommitHandler()

getChannel

public String getChannel()

hasSubscribers

public boolean hasSubscribers()