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, KafkaConnectorIncomingConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	closeQuietly()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	getSource()

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,
                   KafkaConnectorIncomingConfiguration config)

Method Detail

getSource

public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> getSource()

closeQuietly

public void closeQuietly()