This package contains interfaces and classes used to create connections to Kafka.
Interfaces
IKafkaMessageListener
Defines a Kafka message listerner.
Classes
KafkaConnection
Kafka connection using the default driver.
KafkaConnectionResolver
Helper class that resolves a Kafka connection and credential parameters, validates them and generates connection options.
KafkaSubscription
Defines fields for Kafka subscriptions.
KafkaMessage
Defines fields for Kafka messages.