Uses of Interface
io.helidon.messaging.connectors.kafka.KafkaMessage

Packages that use KafkaMessage

Package	Description
io.helidon.messaging.connectors.kafka	Microprofile messaging Kafka connector.

Uses of KafkaMessage in io.helidon.messaging.connectors.kafka

Classes in io.helidon.messaging.connectors.kafka that implement KafkaMessage

Modifier and Type	Class	Description
class	KafkaProducerMessage<K,V>	Kafka specific Micro Profile Reactive Messaging Producer Message.

Methods in io.helidon.messaging.connectors.kafka that return KafkaMessage

Modifier and Type	Method	Description
static <K,V> KafkaMessage<K,V>	KafkaMessage.of(K key, V payload)	Create a message with the given payload and ack function.
static <K,V> KafkaMessage<K,V>	KafkaMessage.of(K key, V payload, Supplier<CompletionStage<Void>> ack)	Create a message with the given payload and ack function.
static <K,V> KafkaMessage<K,V>	KafkaMessage.of(V payload)	Create a message with the given payload and ack function.
static <K,V> KafkaMessage<K,V>	KafkaMessage.of(V payload, Supplier<CompletionStage<Void>> ack)	Create a message with the given payload and ack function.

Method parameters in io.helidon.messaging.connectors.kafka with type arguments of type KafkaMessage

Modifier and Type	Method	Description
void	KafkaPublisher.subscribe(Subscriber<? super KafkaMessage<K,V>> subscriber)