Module io.helidon.messaging.connectors.kafka

Package io.helidon.messaging.connectors.kafka

package io.helidon.messaging.connectors.kafka

Microprofile messaging Kafka connector.

Class	Description
KafkaConfigBuilder	Build Kafka specific config.
KafkaConfigBuilder.AutoOffsetReset	What to do when there is no initial offset in Kafka.
KafkaConnector	Implementation of Kafka Connector as described in the MicroProfile Reactive Messaging Specification.
KafkaMessage<K,V>	Kafka specific Micro Profile Reactive Messaging Message.
KafkaProducerMessage<K,V>	Kafka specific Micro Profile Reactive Messaging Producer Message.
KafkaPublisher<K,V>	This is an implementation of Publisher that read messages from Kafka and push them downstream to one subscriber.
KafkaPublisher.Builder<K,V>	Fluent API builder for KafkaPublisher.
KafkaSubscriber<K,V>	Reactive streams subscriber implementation.
KafkaSubscriber.Builder<K,V>	Fluent API builder for KafkaSubscriber.