Uses of Package
io.helidon.messaging.connectors.kafka
-
ClassDescriptionBuild Kafka specific config.What to do when there is no initial offset in Kafka.Implementation of Kafka Connector as described in the MicroProfile Reactive Messaging Specification.Kafka specific Micro Profile Reactive Messaging Message.This is an implementation of
Publisher
that read messages from Kafka and push them downstream to one subscriber.Fluent API builder forKafkaPublisher
.Reactive streams subscriber implementation.Fluent API builder forKafkaSubscriber
.