@Internal public class KafkaConsumerThread<T> extends Thread
KafkaConsumer, connecting to the brokers and polling records. The thread pushes the data into a
Handoverto be picked up by the fetcher that will deserialize and emit the records.
IMPORTANT: This thread must not be interrupted when attempting to shut it down. The Kafka consumer code was found to not always handle interrupts well, and to even deadlock in certain situations.
Implementation Note: This code is written to be reusable in later versions of the KafkaConsumer. Because Kafka is not maintaining binary compatibility, we use a "call bridge" as an indirection to the KafkaConsumer calls that change signature.
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
|Constructor and Description|
|Modifier and Type||Method and Description|
Shuts this thread down, waking up the thread gracefully if blocked (without Thread.interrupt() calls).
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public KafkaConsumerThread(org.slf4j.Logger log, Handover handover, Properties kafkaProperties, ClosableBlockingQueue<KafkaTopicPartitionState<T,org.apache.kafka.common.TopicPartition>> unassignedPartitionsQueue, String threadName, long pollTimeout, boolean useMetrics, MetricGroup consumerMetricGroup, MetricGroup subtaskMetricGroup)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.