Module io.helidon.messaging.connectors.kafka

Package io.helidon.messaging.connectors.kafka

Class KafkaPublisher<K,V>

java.lang.Object

io.helidon.messaging.connectors.kafka.KafkaPublisher<K,V>

Type Parameters:

K - Key type

V - Value type

All Implemented Interfaces:

Publisher<KafkaMessage<K,V>>

public class KafkaPublisher<K,V>
extends Object
implements Publisher<KafkaMessage<K,V>>

This is an implementation of Publisher that read messages from Kafka and push them downstream to one subscriber. Configurable by Helidon Config,

See Also:

• Config

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	KafkaPublisher.Builder<K,V>	Fluent API builder for KafkaPublisher.

Method Summary

Modifier and Type	Method	Description
static <K, V> KafkaPublisher.Builder<K,V>	builder()	A builder for KafkaPublisher.
static <K, V> KafkaPublisher<K,V>	create(Config config)	Load this builder from a configuration.
protected void	runInNewContext(Runnable runnable)
void	stop()	Closes the opened resources to Kafka and completes exceptionally the pending Message.ack().
void	subscribe(Subscriber<? super KafkaMessage<K,V>> subscriber)

Methods inherited from class java.lang.Object

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

Method Details

stop

public void stop()

Closes the opened resources to Kafka and completes exceptionally the pending Message.ack(). It must be invoked after ScheduledExecutorService is shutdown.

runInNewContext

protected void runInNewContext(Runnable runnable)

subscribe

public void subscribe(Subscriber<? super KafkaMessage<K,V>> subscriber)

Specified by:

subscribe in interface Publisher<K>

builder

public static <K,
V> KafkaPublisher.Builder<K,V> builder()

A builder for KafkaPublisher.

Type Parameters:

K - Key type

V - Value type

Returns:

builder to create a new instance

create

public static <K,
V> KafkaPublisher<K,V> create(Config config)

Load this builder from a configuration.

Type Parameters:

K - Key type

V - Value type

Parameters:

config - configuration to load from

Returns:

updated builder instance