KafkaDataConsumer

KafkaDataConsumer is the abstraction of Kafka consumers that use InternalKafkaConsumer that can be released.

Table 1. KafkaDataConsumer Contract (Abstract Methods Only)
Method Description

internalConsumer

 
internalConsumer: InternalKafkaConsumer

Used when…​FIXME

release

 
release(): Unit

Used when…​FIXME
Table 2. KafkaDataConsumers
KafkaDataConsumer Description

CachedKafkaDataConsumer

NonCachedKafkaDataConsumer

Acquiring Cached KafkaDataConsumer for Partition — acquire Object Method

acquire(
  topicPartition: TopicPartition,
  kafkaParams: ju.Map[String, Object],
  useCache: Boolean
): KafkaDataConsumer

acquire…​FIXME

Note
 acquire is used when…​FIXME

Getting Kafka Record — get Method

get(
  offset: Long,
  untilOffset: Long,
  pollTimeoutMs: Long,
  failOnDataLoss: Boolean
): ConsumerRecord[Array[Byte], Array[Byte]]

get…​FIXME

Note
 get is used when…​FIXME

results matching ""

    No results matching ""