Source file "org/apache/kafka/streams/KafkaStreams.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 2,575 of 2,575 | 0% | 222 of 222 | 0% | 190 | 190 | 543 | 543 | 78 | 78 |
| KafkaStreams(InternalTopologyBuilder, StreamsConfig, KafkaClientSupplier, Time) | | 0% | | 0% | 9 | 9 | 64 | 64 | 1 | 1 |
| removeStreamThread(long) | | 0% | | 0% | 13 | 13 | 54 | 54 | 1 | 1 |
| close(long) | | 0% | | 0% | 12 | 12 | 24 | 24 | 1 | 1 |
| setState(KafkaStreams.State) | | 0% | | 0% | 15 | 15 | 21 | 21 | 1 | 1 |
| addStreamThread() | | 0% | | 0% | 3 | 3 | 23 | 23 | 1 | 1 |
| allLocalStorePartitionLags() | | 0% | | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
| handleStreamsUncaughtException(Throwable, StreamsUncaughtExceptionHandler) | | 0% | | 0% | 9 | 9 | 21 | 21 | 1 | 1 |
| getNextThreadIndex() | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| waitOnState(KafkaStreams.State, long) | | 0% | | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
| createAndAddStreamThread(long, int) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| start() | | 0% | | 0% | 4 | 4 | 16 | 16 | 1 | 1 |
| getMetrics(StreamsConfig, Time, String) | | 0% | n/a | 1 | 1 | 12 | 12 | 1 | 1 | |
| lambda$shutdownHelper$15(boolean) | | 0% | | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
| setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| replaceStreamThread(Throwable) | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| store(StoreQueryParameters) | | 0% | | 0% | 5 | 5 | 6 | 6 | 1 | 1 |
| validateIsRunningOrRebalancing() | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| lambda$getNextThreadIndex$9(HashSet, AtomicInteger, StreamThread) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| lambda$getNumLiveStreamThreads$8(AtomicInteger, StreamThread) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| getNumStreamThreads(boolean) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| lambda$localThreadsMetadata$20(ThreadMetadata) | | 0% | n/a | 1 | 1 | 11 | 11 | 1 | 1 | |
| defaultStreamsUncaughtExceptionHandler(Throwable) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| setStateListener(KafkaStreams.StateListener) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| setGlobalStateRestoreListener(StateRestoreListener) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| closeToError() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| close(Duration) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| metrics() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| lambda$allLocalStorePartitionLags$22(Collection, Map, StreamThread) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| cleanUp() | | 0% | | 0% | 4 | 4 | 4 | 4 | 1 | 1 |
| processStreamThread(Consumer) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getNumLiveStreamThreads() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| shutdownHelper(boolean) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$setupStateDirCleaner$11(Runnable) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| getCacheSizePerThread(int) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
| lambda$metadataForLocalThreads$21(Set, StreamThread) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| lambda$maybeCreateRocksDBMetricsRecordingService$12(String, Runnable) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$null$19(TaskMetadata) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| lambda$null$18(TaskMetadata) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| lambda$allMetadataForStore$17(StreamsMetadata) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| lambda$allMetadata$16(StreamsMetadata) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| KafkaStreams(Topology, Properties, Time) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| allMetadataForStore(String) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$metrics$5(Map, StreamThread) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| KafkaStreams(Topology, Properties) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| removeStreamThread(Duration) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| resizeThreadCache(long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| maybeCreateRocksDBMetricsRecordingService(String, StreamsConfig) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| allMetadata() | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| isRunningOrRebalancing() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KafkaStreams(Topology, Properties, KafkaClientSupplier) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KafkaStreams(Topology, Properties, KafkaClientSupplier, Time) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KafkaStreams(Topology, StreamsConfig, Time) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| metadataForLocalThreads() | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$null$14(StreamThread) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| lambda$start$13(Long) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| parseHostInfo(String) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| queryMetadataForKey(String, Object, Serializer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| queryMetadataForKey(String, Object, StreamPartitioner) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| localThreadsMetadata() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KafkaStreams(Topology, StreamsConfig) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KafkaStreams(Topology, StreamsConfig, KafkaClientSupplier) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| KafkaStreams(InternalTopologyBuilder, StreamsConfig, KafkaClientSupplier) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| streamsMetadataForStore(String) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| metadataForAllStreamsClients() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| close() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$setUncaughtExceptionHandler$1(StreamsUncaughtExceptionHandler, Throwable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| removeStreamThread() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| setupStateDirCleaner() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$allLocalStorePartitionLags$23(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$resizeThreadCache$10(long, StreamThread) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$new$7(MetricConfig, long) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$handleStreamsUncaughtException$4(StreamThread) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$setUncaughtExceptionHandler$2(Consumer, StreamThread) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$setUncaughtExceptionHandler$0(Thread.UncaughtExceptionHandler, StreamThread) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| state() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$new$6(MetricConfig, long) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$defaultStreamsUncaughtExceptionHandler$3(Throwable) | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |