Module io.helidon.messaging.connectors.kafka

Package io.helidon.messaging.connectors.kafka

Class KafkaSubscriber<K,V>

java.lang.Object

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

Type Parameters:

K - kafka record key type

V - kafka record value type

All Implemented Interfaces:

Subscriber<Message<V>>

public class KafkaSubscriber<K,V>
extends Object
implements Subscriber<Message<V>>

Reactive streams subscriber implementation.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method	Description
static <K, V> KafkaSubscriber.Builder<K,V>	builder()	A builder for KafkaSubscriber.
static <K, V> KafkaSubscriber<K,V>	create(Config config)	Load this builder from a configuration.
void	onComplete()
void	onError(Throwable t)
void	onNext(Message<V> message)
void	onSubscribe(Subscription subscription)

Methods inherited from class java.lang.Object

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

Method Details

onSubscribe

public void onSubscribe(Subscription subscription)

Specified by:

onSubscribe in interface Subscriber<K>

onNext

public void onNext(Message<V> message)

Specified by:

onNext in interface Subscriber<K>

onError

public void onError(Throwable t)

Specified by:

onError in interface Subscriber<K>

onComplete

public void onComplete()

Specified by:

onComplete in interface Subscriber<K>

builder

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

A builder for KafkaSubscriber.

Type Parameters:

K - Key type

V - Value type

Returns:

builder to create a new instance

create

public static <K,
V> KafkaSubscriber<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