AbstractKafkaStreamsBinderProcessor

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,104 of 1,1040%111 of 1110%88882722723232
buildStreamsBuilderAndRetrieveConfig(String, ApplicationContext, String, KafkaStreamsBinderConfigurationProperties, StreamsBuilderFactoryBeanConfigurer, ConfigurableEnvironment, BindingProperties)2980%420%2222808011
getKStream(String, BindingProperties, KafkaStreamsConsumerProperties, StreamsBuilder, Serde, Serde, Topology.AutoOffsetReset, boolean)1280%100%66303011
handleKTableGlobalKTableInputs(Object[], int, String, Class, Object, StreamsBuilderFactoryBean, StreamsBuilder, KafkaStreamsConsumerProperties, Serde, Serde, Topology.AutoOffsetReset, boolean)970%60%44242411
getKTable(KafkaStreamsConsumerProperties, StreamsBuilder, Serde, Serde, String, String, Topology.AutoOffsetReset)880%60%44191911
handleConcurrency(ApplicationContext, String, Map)620%40%33161611
getConsumed(KafkaStreamsConsumerProperties, Serde, Serde, Topology.AutoOffsetReset)370%60%44101011
lambda$getkStream$8(BindingProperties, AtomicReference, Object)340%40%33101011
getAutoOffsetReset(String, KafkaStreamsConsumerProperties)290%70%55101011
getMaterialized(String, Serde, Serde, Boolean, Boolean)290%80%55111111
materializedAs(StreamsBuilder, String, String, Serde, Serde, Topology.AutoOffsetReset, KafkaStreamsConsumerProperties)260%n/a113311
materializedAsGlobalKTable(StreamsBuilder, String, String, Serde, Serde, Topology.AutoOffsetReset, KafkaStreamsConsumerProperties)260%n/a114411
getGlobalKTable(KafkaStreamsConsumerProperties, StreamsBuilder, Serde, Serde, String, String, Topology.AutoOffsetReset)240%20%224411
getkStream(BindingProperties, KStream, boolean)220%20%225511
getValueSerde(String, KafkaStreamsConsumerProperties, ResolvableType)210%20%226611
AbstractKafkaStreamsBinderProcessor(BindingServiceProperties, KafkaStreamsBindingInformationCatalogue, KafkaStreamsExtendedBindingProperties, KeyValueSerdeResolver, CleanupConfig)180%n/a117711
lambda$buildStreamsBuilderAndRetrieveConfig$1(String, String)180%n/a116611
addStateStoreBeans(StreamsBuilder)160%20%226611
getValueSerdeToUse(KafkaStreamsConsumerProperties, Serde)150%40%333311
lambda$getKTable$12(Serde, AtomicReference, AtomicReference, Object)130%n/a112211
lambda$getKTable$11(Object, Object)130%20%224411
lambda$addStateStoreBeans$9(StreamsBuilder, StoreBuilder)130%20%224411
lambda$getKStream$5(Serde, AtomicReference, AtomicReference, Object)130%n/a112211
lambda$getKStream$4(Object, Object)130%20%224411
eventTypeProcessor(KafkaStreamsConsumerProperties, AtomicReference, AtomicReference)80%n/a111111
lambda$getkStream$7(Map, Header)80%n/a111111
static {...}70%n/a112211
lambda$getKTable$10(KafkaStreamsConsumerProperties, AtomicReference, AtomicReference)60%n/a111111
lambda$getkStream$6(AtomicReference)60%n/a111111
lambda$getKStream$3(KafkaStreamsConsumerProperties, AtomicReference, AtomicReference)60%n/a111111
setApplicationContext(ApplicationContext)50%n/a112211
lambda$static$0()30%n/a111111
lambda$buildStreamsBuilderAndRetrieveConfig$2(StreamsBuilderFactoryBean)0%n/a111111