Source file "org/apache/kafka/streams/processor/internals/StreamTask.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 2,291 of 2,291 | 0% | 153 of 153 | 0% | 150 | 150 | 469 | 469 | 64 | 64 |
| StreamTask(TaskId, Set, ProcessorTopology, Consumer, StreamsConfig, StreamsMetricsImpl, StateDirectory, ThreadCache, Time, ProcessorStateManager, RecordCollector, InternalProcessorContext, LogContext) | | 0% | | 0% | 4 | 4 | 51 | 51 | 1 | 1 |
| process(long) | | 0% | | 0% | 6 | 6 | 49 | 49 | 1 | 1 |
| committableOffsetsAndMetadata() | | 0% | | 0% | 6 | 6 | 22 | 22 | 1 | 1 |
| punctuate(ProcessorNode, long, PunctuationType, Punctuator) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| postCommit(boolean) | | 0% | | 0% | 7 | 7 | 14 | 14 | 1 | 1 |
| resetOffsetsIfNeededAndInitializeMetadata(Consumer) | | 0% | | 0% | 4 | 4 | 21 | 21 | 1 | 1 |
| close(boolean) | | 0% | | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
| initializeTaskTime(Map) | | 0% | | 0% | 4 | 4 | 17 | 17 | 1 | 1 |
| toString(String) | | 0% | | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
| prepareCommit() | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| resume() | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| suspend() | | 0% | | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
| closeCleanAndRecycleState() | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| completeRestoration(Consumer) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| schedule(long, long, PunctuationType, Punctuator) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| isProcessable(long) | | 0% | | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
| purgeableOffsets() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| closeTopology() | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| schedule(long, PunctuationType, Punctuator) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| checkpointableOffsets() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| maybeRecordE2ELatency(long, long, String) | | 0% | | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
| initializeIfNeeded() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| removeAllSensors() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| getStacktraceString(RuntimeException) | | 0% | n/a | 1 | 1 | 9 | 9 | 1 | 1 | |
| initializeTopology() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| extractPartitionTimes() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| decodeTimestamp(String) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| addRecords(TopicPartition, Iterable) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| createPartitionQueues() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| maybePunctuateStreamTime() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| recordProcessTimeRatioAndBufferSize(long, long) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| maybePunctuateSystemTime() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| changelogOffsets() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| encodeTimestamp(long) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| updateInputPartitions(Set, Map) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| transitToSuspend() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| closeClean() | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| maybeWriteCheckpoint(boolean) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| lambda$close$0(boolean) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| validateClean() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| updateProcessorContext(ProcessorNode, long, ProcessorRecordContext) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| closeDirty() | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| addPartitionsForOffsetReset(Set) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| clearCommitStatuses() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| recordProcessBatchTime(long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updateCommittedOffsets(TopicPartition, Long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| updateEndOffsets(TopicPartition, Long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| hasRecordsQueued() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$resetOffsetsIfNeededAndInitializeMetadata$3(Map.Entry) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$punctuate$2(ProcessorNode, long, Punctuator) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| requestCommit() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| toString() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| committedOffsets() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| highWaterMark() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| numBuffered() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| streamTime() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$process$1(ProcessorNode, Record) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| commitRequested() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| processorContext() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| commitNeeded() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| timeCurrentIdlingStarted() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| recordCollector() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$changelogOffsets$4(TopicPartition) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| isActive() | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |