io.smallrye.reactive.messaging.kafka

Class KafkaConnector

java.lang.Object

io.smallrye.reactive.messaging.kafka.KafkaConnector

All Implemented Interfaces:

HealthReporter, ConnectorFactory, IncomingConnectorFactory, OutgoingConnectorFactory

@ApplicationScoped
public class KafkaConnector
extends Object
implements IncomingConnectorFactory, OutgoingConnectorFactory, HealthReporter

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECTOR_NAME
static io.opentelemetry.api.trace.Tracer	TRACER

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory

CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX

Constructor Summary

Constructors

Constructor and Description
KafkaConnector()

Method Summary

Modifier and Type	Method and Description
<K,V> KafkaConsumer<K,V>	getConsumer(String channel)
HealthReport	getLiveness()
<K,V> org.apache.kafka.clients.producer.Producer<K,V>	getProducer(String channel)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	getPublisherBuilder(org.eclipse.microprofile.config.Config config) Creates a channel for the given configuration.
HealthReport	getReadiness()
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	getSubscriberBuilder(org.eclipse.microprofile.config.Config config) Creates a channel for the given configuration.
void	terminate(Object event)

Methods inherited from class java.lang.Object

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

Field Detail

CONNECTOR_NAME

public static final String CONNECTOR_NAME

See Also:

Constant Field Values

TRACER

public static io.opentelemetry.api.trace.Tracer TRACER

Constructor Detail

KafkaConnector

public KafkaConnector()

Method Detail

terminate

public void terminate(@Observes(notifyObserver=IF_EXISTS) @Priority(value=50) @BeforeDestroyed(value=javax.enterprise.context.ApplicationScoped.class)
                      Object event)

getPublisherBuilder

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

Description copied from interface: IncomingConnectorFactory

Creates a channel for the given configuration. The channel's configuration is associated with a specific connector, using the Connector qualifier's parameter indicating a key to which IncomingConnectorFactory to use.

Note that the connection to the transport or broker is generally postponed until the subscription occurs.

Specified by:

getPublisherBuilder in interface IncomingConnectorFactory

Parameters:

config - the configuration, must not be null, must contain the ConnectorFactory.CHANNEL_NAME_ATTRIBUTE attribute.

Returns:

the created PublisherBuilder, will not be null.

getSubscriberBuilder

public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> getSubscriberBuilder(org.eclipse.microprofile.config.Config config)

Description copied from interface: OutgoingConnectorFactory

Creates a channel for the given configuration. The channel's configuration is associated with a specific connector, using the Connector qualifier's parameter indicating a key to which Outgoing to use.

Note that the connection to the transport or broker is generally postponed until the subscription.

Specified by:

getSubscriberBuilder in interface OutgoingConnectorFactory

Parameters:

config - the configuration, never null, must contain the ConnectorFactory.CHANNEL_NAME_ATTRIBUTE attribute.

Returns:

the created SubscriberBuilder, must not be null.

getReadiness

public HealthReport getReadiness()

Specified by:

getReadiness in interface HealthReporter

getLiveness

public HealthReport getLiveness()

Specified by:

getLiveness in interface HealthReporter

getConsumer

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

getProducer

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