Package org.apache.kafka.clients.consumer.internals

Interface ConsumerDelegate<K,V>

All Superinterfaces:

AutoCloseable, Closeable, Consumer<K,V>

All Known Implementing Classes:

AsyncKafkaConsumer, LegacyKafkaConsumer

public interface ConsumerDelegate<K,V>
extends Consumer<K,V>

This extension interface provides a handful of methods to expose internals of the Consumer for various tests.

Note: this is for internal use only and is not intended for use by end users. Internal users should not attempt to determine the underlying implementation to avoid coding to an unstable interface. Rather, it is the Consumer API contract that should serve as the caller's interface.

Method Summary

Modifier and Type	Method	Description
String	clientId()
KafkaConsumerMetrics	kafkaConsumerMetrics()
org.apache.kafka.common.metrics.Metrics	metricsRegistry()
boolean	updateAssignmentMetadataIfNeeded(org.apache.kafka.common.utils.Timer timer)

Methods inherited from interface org.apache.kafka.clients.consumer.Consumer

assign, assignment, beginningOffsets, beginningOffsets, clientInstanceId, close, close, commitAsync, commitAsync, commitAsync, commitSync, commitSync, commitSync, commitSync, committed, committed, committed, committed, currentLag, endOffsets, endOffsets, enforceRebalance, enforceRebalance, groupMetadata, listTopics, listTopics, metrics, offsetsForTimes, offsetsForTimes, partitionsFor, partitionsFor, pause, paused, poll, poll, position, position, resume, seek, seek, seekToBeginning, seekToEnd, subscribe, subscribe, subscribe, subscribe, subscription, unsubscribe, wakeup

Method Details

clientId

String clientId()

metricsRegistry

org.apache.kafka.common.metrics.Metrics metricsRegistry()

kafkaConsumerMetrics

KafkaConsumerMetrics kafkaConsumerMetrics()

updateAssignmentMetadataIfNeeded

boolean updateAssignmentMetadataIfNeeded(org.apache.kafka.common.utils.Timer timer)