Skip to content


Creating Instance

RecordQueueCreator takes the following to be created:

RecordQueueCreator is created when:

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:

Back to top