Connect

This package contains interfaces and classes used to create connections to Kafka.

Interfaces

IKafkaMessageListener

Defines a Kafka message listerner.


Types

KafkaConnection

Kafka connection using the default driver.

KafkaConnectionResolver

Resolves a Kafka connection and credential parameters, validates them and generates connection options.

KafkaMessage

Defines Kafka message fields.

KafkaSubscription

Defines fields for Kafka subscriptions.