Module io.helidon.messaging.connectors.kafka

Package io.helidon.messaging.connectors.kafka

Microprofile messaging Kafka connector.

Interface Summary

Interface	Description
KafkaMessage<K,V>	Kafka specific Micro Profile Reactive Messaging Message.

Class Summary

Class	Description
KafkaConfigBuilder	Build Kafka specific config.
KafkaConnector	Implementation of Kafka Connector as described in the MicroProfile Reactive Messaging Specification.
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.

Enum Summary

Enum	Description
KafkaConfigBuilder.AutoOffsetReset	What to do when there is no initial offset in Kafka.