RecordQueueCreator¶

Creating Instance¶

RecordQueueCreator takes the following to be created:

• LogContext
• default.timestamp.extractor configuration property
• default.deserialization.exception.handler configuration property

RecordQueueCreator is created when:

• StreamTask is created

Creating RecordQueue¶

RecordQueue createQueue(
  TopicPartition partition)

createQueue requests the ProcessorTopology for the SourceNode for the topic (of the given TopicPartition).

createQueue determines the TimestampExtractor that is one of the following:

1. TimestampExtractor of the SourceNode if defined
2. Default TimestampExtractor

createQueue is used when:

• StreamTask is requested to createPartitionQueues and updateInputPartitions