NewKafkaConnection creates a new instance of the connection component.

Kafka connection using plain driver.

KafkaConnectionResolver helper class that resolves Kafka connection and credential parameters, validates them and generates connection options.

Kafka message structure.

Subscription structure.