See: Description
Class | Description |
---|---|
KafkaMessageTransformer |
A transformer that transforms the Kafka messages into
Map of partition and payload. |
KafkaOptionMixin |
Kafka module options mixin.
|
KafkaSourceModuleOptionsMetadata |
Module options for Kafka source module.
|
StringDecoder |
String Decoder for Kafka message key/value decoding.
|