org.springframework.cloud.stream.binder.kafka.streams

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethodsMissedClasses
Total14,551 of 14,5510%857 of 8570%1,1201,1203,0643,064691691122122
KafkaStreamsFunctionProcessor1,4560%1880%113113277277191911
AbstractKafkaStreamsBinderProcessor1,1040%1110%8888272272323211
KafkaStreamsFunctionCompositionTests7680%n/a1111128128111111
KafkaStreamsInteractiveQueryIntegrationTests6020%n/a991111119911
KafkaStreamsBinderSupportAutoConfiguration5630%600%5252122122222211
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes5310%n/a7759597711
KafkaStreamsEventTypeRoutingTests5120%n/a7786867711
MultipleFunctionsInSameAppTests5010%n/a7773737711
KafkaStreamsBinderUtils4900%640%4646103103141411
KafkaStreamsBinderHealthIndicator4560%340%25251011018811
KeyValueSerdeResolver4210%540%47479898202011
InteractiveQueryService4000%260%3232101101191911
KafkaStreamsBinderMetrics3910%520%44449595181811
ExtendedBindingHandlerMappingsProviderAutoConfigurationTests3640%n/a15159292151511
EventTypeRoutingWithInferredSerdeTests3300%n/a5550505511
InteractiveQueryServiceMultiStateStoreTests3170%40%14145757121211
KafkaStreamsMessageConversionDelegate3160%220%26267474151511
KStreamBinder2880%160%19196969111111
KafkaStreamsBindingInformationCatalogue2490%80%31316060272711
SerdeResolverUtils2490%320%252566669911
KafkaStreamsVersionAgnosticTopologyInfoFacade2210%200%161642426611
StreamsBuilderFactoryManager1740%240%212152529911
SerdeResolverUtilsTests.ResolveForType.NoMatchingSerdeBeans1730%n/a4416164411
KafkaStreamsMessageConversionDelegate.new Processor() {...}1360%120%101032324411
SerdeResolverUtilsTests.ResolveForType.NoMatchingSerdeBeans.ForNonKafkaStreamsBuiltInType1280%n/a10102828101011
KStreamBoundElementFactory1180%80%8831314411
KafkaStreamsRegistry1110%80%121226268811
KTableBinder1030%20%9928288811
GlobalKTableBinder1020%20%9927278811
AbstractKafkaStreamsBinderProcessor.new Processor() {...}980%100%9920204411
InteractiveQueryServiceMultiStateStoreTests.MultipleAppsWithUsedStateStoresTestApplication940%n/a12121515121211
SerdeResolverUtilsTests.ResolveForType900%n/a5518185511
KStreamBinder.new DefaultBinding() {...}840%60%7717174411
KTableBinder.new DefaultBinding() {...}840%60%7717174411
GlobalKTableBinder.new DefaultBinding() {...}800%60%7717174411
KStreamBinder.new DefaultBinding() {...}800%60%7717174411
MultipleFunctionsInSameAppTests.MultipleFunctionsInSameApp790%n/a15151717151511
KTableBoundElementFactory790%40%5520203311
GlobalKTableBoundElementFactory790%40%5520203311
InteractiveQueryServiceMultiStateStoreTests.MultipleAppsWithUnusedStateStoresTestApplication780%n/a12121313121211
KStreamBinderConfiguration730%n/a5524245511
KafkaStreamsBinderEnvironmentPostProcessorTests700%n/a4415154411
SerdeResolverUtilsTests.SerdeResolverComplexTestApp690%n/a15151515151511
RecordRecoverableProcessor640%20%9925258811
EncodingDecodingBindAdviceHandler.new AbstractBindHandler() {...}630%120%8811112211
KafkaStreamsInteractiveQueryIntegrationTests.ProductCountApplication600%20%99888811
KafkaStreamsMessageConversionDelegate.new Processor() {...}580%40%6615154411
GlobalKTableBinderConfiguration570%n/a5519195511
KTableBinderConfiguration570%n/a5519195511
KStreamBoundElementFactory.KStreamWrapperHandler550%60%7716164411
InteractiveQueryServiceMultiStateStoreTests.StoreQueryParameterCustomizerTestApplication550%n/a88998811
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.NegativeCases540%n/a4411114411
DltAwareProcessor500%20%5515154411
KTableBoundElementFactory.KTableWrapperHandler490%60%5514142211
GlobalKTableBoundElementFactory.GlobalKTableWrapperHandler490%60%5515152211
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig5440%n/a141466141411
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.KafkaStreams33440%n/a33773311
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.KafkaStreams30440%n/a33773311
KafkaStreamsMessageConversionDelegate.new Processor() {...}440%40%6612124411
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.KafkaStreams31_32440%n/a33773311
KafkaStreamsBinderUtilsTests430%n/a22992211
KafkaStreamsEventTypeRoutingTests.Foo420%60%8811115511
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig4410%n/a131355131311
AbstractKafkaStreamsBinderProcessor.new BindHandler() {...}410%60%55662211
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig1380%n/a101099101011
SendToDlqAndContinue370%n/a44994411
SerdeResolverUtilsTests.SerdeResolverSimpleTestApp340%n/a88888811
KafkaStreamsJaasConfiguration300%40%4411112211
KafkaStreamsBinderEnvironmentPostProcessor280%20%33882211
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig2270%n/a77887711
DeserializationExceptionHandler270%n/a11551111
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests270%n/a22772211
ExtendedBindingHandlerMappingsProviderAutoConfiguration250%n/a3310103311
AbstractKafkaStreamsBinderProcessor.new Processor() {...}240%n/a44884411
SerdeResolverUtils.SerdeWithSpecificityScore220%n/a33663311
KafkaStreamsBinderSupportAutoConfiguration.KafkaStreamsBinderMetricsConfigurationWithMultiBinder200%n/a22442211
KafkaStreamsEventTypeRoutingTests.EventTypeRoutingTestConfig200%n/a88778811
DltPublishingContext190%n/a44664411
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig3180%n/a55665511
KafkaStreamsBinderHealthIndicatorConfiguration180%20%33442211
KafkaStreamsInteractiveQueryIntegrationTests.ProductCountApplication.Foo180%n/a22772211
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig6170%n/a44554411
EncodingDecodingBindAdviceHandler160%n/a44444411
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreams30160%n/a22552211
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestToplogyInfoTwoArgs150%20%33442211
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestToplogyInfoOneArg150%20%33442211
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreamsThrowsError140%n/a11331111
SerdeResolverUtilsTests.GenericEventSerde140%n/a44664411
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreamsThrowsError.new KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestToplogyInfoOneArg() {...}130%n/a22222211
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreams31_320%n/a11331111
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreams330%n/a11331111
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreamsNoSourceTopicsMethod0%n/a11331111
KafkaStreamsBinderSupportAutoConfiguration.KafkaStreamsBinderMetricsConfiguration.KafkaMicrometer0%n/a22222211
KafkaStreamsBinderSupportAutoConfiguration.KafkaStreamsBinderMetricsConfiguration0%n/a22222211
KafkaStreamsBinderSupportAutoConfiguration.KafkaStreamsBinderMetricsConfigurationWithMultiBinder.KafkaMicrometer0%n/a22222211
KafkaStreamsInteractiveQueryIntegrationTests.Product0%n/a33443311
KafkaStreamsFunctionCompositionTests.FunctionCompositionConfig6.new ForeachAction() {...}0%n/a22332211
MultiBinderPropertiesConfiguration0%n/a22222211
KafkaStreamsBinderSupportAutoConfiguration.EmptyObjectProvider0%n/a44444411
KafkaStreamsMessageConversionDelegate.PerRecordContentTypeHolder0%n/a22442211
EventTypeRoutingWithInferredSerdeTests.EventTypeRoutingWithConfiguredSerdeConfig0%n/a33223311
SerdeResolverUtilsTests.FooSerde0%n/a33333311
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SkipAndContinueExceptionHandler0%n/a33333311
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
SerdeResolverUtilsTests.BeanNamesForMatchingSerdes.new ParameterizedTypeReference() {...}0%n/a11111111
KafkaStreamsBinderEnvironmentPostProcessorTests.SimpleKafkaStreamsApplication0%n/a33333311
InteractiveQueryServiceMultiStateStoreTests.EchoProcessor0%n/a33333311
SerdeResolverUtilsTests.Foo0%n/a11111111
SerdeResolverUtilsTests.GenericEvent0%n/a11111111
KafkaStreamsVersionAgnosticTopologyInfoFacadeTests.TestKafkaStreamsNoSourceTopicsMethod.TestTopologyInfoNoSourceTopicsMethod0%n/a11111111
ExtendedBindingHandlerMappingsProviderAutoConfigurationTests.KafkaStreamsTestApp0%n/a11111111
SerdeResolverUtilsTests0%n/a11111111