See: Description
| Class | Description |
|---|---|
| InitialOffsetsFactoryBean |
Parses the list of initial offsets and creates a map to initialize the
OffsetManager |
| KafkaConsumerOptionsMixin |
Module options for Kafka consumer configuration.
|
| KafkaMessageTransformer |
A transformer that transforms the Kafka messages into
Map of partition and payload. |
| KafkaOffsetTopicOptionsMixin | |
| KafkaPartitionAllocator |
Is responsible for managing the partition allocation between multiple instances of a Kafka source module
deployed in a stream.
|
| KafkaProducerOptionsMixin |
Module options for Kafka Producer configuration.
|
| KafkaSinkModuleOptionsMetadata |
Module options for Kafka sink module.
|
| KafkaSourceModuleOptionsMetadata |
Module options for Kafka source module.
|
| KafkaZKOptionMixin |
Kafka module options mixin for ZK configuration.
|
| NamespaceDelegatingMetadataStore |
Wraps a delegate
MetadataStore and adds a prefix to all the handled keys. |
| WindowingOffsetManager |
An
OffsetManager that aggregates writes over a time or count window, using an underlying delegate to
do the actual operations. |
| Enum | Description |
|---|---|
| AutoOffsetResetStrategy |
The possible values for automatically resetting the offset of Kafka client
|
| KafkaSourceModuleOptionsMetadata.OffsetStorageStrategy |