Skip to content


== [[KafkaDataConsumer]] KafkaDataConsumer

KafkaDataConsumer is the <> of <> that use <> that can be <>.

[[contract]] .KafkaDataConsumer Contract (Abstract Methods Only) [cols="30m,70",options="header",width="100%"] |=== | Method | Description

| internalConsumer a| [[internalConsumer]]

[source, scala]

internalConsumer: InternalKafkaConsumer

Used when...FIXME

| release a| [[release]]

[source, scala]

release(): Unit

Used when...FIXME


[[implementations]] .KafkaDataConsumers [cols="30,70",options="header",width="100%"] |=== | KafkaDataConsumer | Description

| CachedKafkaDataConsumer | [[CachedKafkaDataConsumer]]

| NonCachedKafkaDataConsumer | [[NonCachedKafkaDataConsumer]]


=== [[acquire]] Acquiring Cached KafkaDataConsumer for Partition -- acquire Object Method

[source, scala]

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


NOTE: acquire is used when...FIXME

=== [[get]] Getting Kafka Record -- get Method

[source, scala]

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


NOTE: get is used when...FIXME