Connect

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.