Package 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	Description
KafkaSource(io.vertx.mutiny.core.Vertx vertx, String group, KafkaConnectorIncomingConfiguration config, javax.enterprise.inject.Instance<KafkaConsumerRebalanceListener> consumerRebalanceListeners, KafkaCDIEvents kafkaCDIEvents)

Method Summary

Modifier and Type	Method	Description
void	closeQuietly()
io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K,V>	getConsumer()	For testing purpose only
io.smallrye.mutiny.Multi<IncomingKafkaRecord<K,V>>	getStream()
void	incomingTrace(IncomingKafkaRecord<K,V> kafkaRecord)
void	isAlive(HealthReport.HealthReportBuilder builder)
void	isReady(HealthReport.HealthReportBuilder builder)
void	reportFailure(Throwable failure)

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 group,
                   KafkaConnectorIncomingConfiguration config,
                   javax.enterprise.inject.Instance<KafkaConsumerRebalanceListener> consumerRebalanceListeners,
                   KafkaCDIEvents kafkaCDIEvents)

Method Detail

reportFailure

public void reportFailure(Throwable failure)

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 io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<K,V> getConsumer()

For testing purpose only

Returns:

get the underlying consumer.