internalConsumer: InternalKafkaConsumer
KafkaDataConsumer
KafkaDataConsumer
is the abstraction of Kafka consumers that use InternalKafkaConsumer that can be released.
Method | Description |
---|---|
|
Used when…FIXME |
|
Used when…FIXME |
KafkaDataConsumer | Description |
---|---|
CachedKafkaDataConsumer |
|
NonCachedKafkaDataConsumer |