ActiveTaskCreator

Source file "org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total453 of 4530%20 of 200%232391911313
ActiveTaskCreator(InternalTopologyBuilder, StreamsConfig, StreamsMetricsImpl, StateDirectory, ChangelogReader, ThreadCache, Time, KafkaClientSupplier, String, UUID, Logger)870%20%22222211
createTasks(Consumer, Map)770%20%22141411
createActiveTask(TaskId, Set, Consumer, LogContext, ProcessorTopology, ProcessorStateManager, InternalProcessorContext)770%20%22111111
streamsProducerForTask(TaskId)390%40%336611
getLogContext(TaskId)350%n/a113311
createActiveTaskFromStandby(StandbyTask, Set, Consumer)330%n/a117711
closeAndRemoveTaskProducerIfNeeded(TaskId)280%20%227711
threadProducer()200%20%223311
producerClientIds()190%20%226611
closeThreadProducerIfNeeded()150%20%226611
producerMetrics()140%20%224411
lambda$producerClientIds$0(TaskId)50%n/a111111
reInitializeThreadProducer()40%n/a112211