DefaultKafkaProducerFactory

Source file "org/springframework/kafka/core/DefaultKafkaProducerFactory.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,309 of 1,3090%122 of 1220%1511513143149090
DefaultKafkaProducerFactory(Map, Supplier, Supplier, boolean)1050%60%44242411
copyWithConfigurationOverride(Map)700%40%33171711
lambda$updateConfigs$14(Map.Entry)640%100%66111111
doCreateProducer(String)630%120%77141411
getOrCreateThreadBoundProducer()610%100%66121211
doCreateTxProducer(String, String, BiPredicate)610%n/a11151511
cacheReturner(DefaultKafkaProducerFactory.CloseSafeProducer, Duration)500%100%66121211
destroy()480%20%22131311
createTransactionalProducerForPartition(String)460%60%44101011
createTransactionalProducer(String)430%60%449911
removeConsumerProducer(DefaultKafkaProducerFactory.CloseSafeProducer, Duration)420%60%44111111
createRawProducer(Map)320%20%226611
getProducerConfigs()310%20%226611
expire(DefaultKafkaProducerFactory.CloseSafeProducer)270%60%444411
closeProducerFor(String)260%40%337711
ensureExistingTransactionIdPrefixInProperties(Map)240%40%337711
lambda$destroy$16(BlockingQueue)240%20%228811
removeProducer(DefaultKafkaProducerFactory.CloseSafeProducer, Duration)230%40%337711
addListener(int, ProducerFactory.Listener)200%20%225511
closeThreadBoundProducer()170%20%225511
keySerializerSupplier(Supplier)160%40%336611
valueSerializerSupplier(Supplier)160%40%336611
enableIdempotentBehaviour()150%20%224411
lambda$valueSerializerSupplier$9(Supplier)130%20%224411
lambda$keySerializerSupplier$7(Supplier)130%20%224411
getConfigurationProperties()120%n/a113311
createProducer(String)110%20%222211
getCache(String)110%20%223311
lambda$updateConfigs$13(Map.Entry)110%n/a112211
lambda$updateConfigs$12(Map.Entry)110%n/a112211
getTxProducerConfigs(String)100%n/a113311
DefaultKafkaProducerFactory(Map, Serializer, Serializer)90%n/a112211
DefaultKafkaProducerFactory(Map, Serializer, Serializer, boolean)90%n/a112211
setTransactionIdPrefix(String)90%n/a114411
addListener(ProducerFactory.Listener)90%n/a113311
addPostProcessor(ProducerPostProcessor)90%n/a113311
onApplicationEvent(ContextStoppedEvent)90%20%223311
reset()90%n/a115511
lambda$createTransactionalProducer$19(String)90%n/a111111
lambda$doCreateProducer$18(ProducerFactory.Listener)80%n/a111111
DefaultKafkaProducerFactory(Map, Supplier, Supplier)70%n/a112211
setKeySerializer(Serializer)70%n/a112211
setValueSerializer(Serializer)70%n/a112211
transactionCapable()70%20%221111
lambda$destroy$17(String, DefaultKafkaProducerFactory.CloseSafeProducer)70%n/a111111
static {...}70%n/a111111
DefaultKafkaProducerFactory(Map)60%n/a112211
setKeySerializerSupplier(Supplier)60%n/a112211
setValueSerializerSupplier(Supplier)60%n/a112211
setPhysicalCloseTimeout(int)60%n/a112211
updateConfigs(Map)60%n/a112211
removeConfig(String)60%n/a112211
lambda$doCreateTxProducer$20(DefaultKafkaProducerFactory.CloseSafeProducer, ProducerFactory.Listener)60%n/a111111
getKeySerializer()50%n/a111111
getValueSerializer()50%n/a111111
setMaxAge(Duration)50%n/a112211
removeListener(ProducerFactory.Listener)50%n/a111111
removePostProcessor(ProducerPostProcessor)50%n/a111111
createProducer()50%n/a111111
createKafkaProducer()50%n/a111111
createTransactionalProducerForPartition()50%n/a111111
createTransactionalProducer()50%n/a111111
getCache()50%n/a111111
setApplicationContext(ApplicationContext)40%n/a112211
setBeanName(String)40%n/a112211
setConfigureSerializers(boolean)40%n/a112211
setProducerPerThread(boolean)40%n/a112211
setProducerPerConsumerPartition(boolean)40%n/a112211
getListeners()40%n/a111111
getPostProcessors()40%n/a111111
createNonTransactionalProducer()40%n/a111111
lambda$getCache$21(String)40%n/a111111
isConfigureSerializers()30%n/a111111
getPhysicalCloseTimeout()30%n/a111111
getTransactionIdPrefix()30%n/a111111
isProducerPerThread()30%n/a111111
isProducerPerConsumerPartition()30%n/a111111
getKeySerializerSupplier()30%n/a111111
getValueSerializerSupplier()30%n/a111111
lambda$enableIdempotentBehaviour$15()20%n/a111111
lambda$setValueSerializer$11(Serializer)20%n/a111111
lambda$setKeySerializer$10(Serializer)20%n/a111111
lambda$valueSerializerSupplier$8()20%n/a111111
lambda$keySerializerSupplier$6()20%n/a111111
lambda$new$5(Serializer)20%n/a111111
lambda$new$4(Serializer)20%n/a111111
lambda$new$3(Serializer)20%n/a111111
lambda$new$2(Serializer)20%n/a111111
lambda$new$1()20%n/a111111
lambda$new$0()20%n/a111111