| createConsumerEndpointCaptureHelper(ConsumerDestination, String, ExtendedConsumerProperties) |  | 0% | | 0% | 44 | 44 | 124 | 124 | 1 | 1 |
| handleRecordForDlq(ConsumerRecord, ConsumerDestination, String, ExtendedConsumerProperties, KafkaConsumerProperties, KafkaProducerProperties, KafkaAwareTransactionManager, KafkaMessageChannelBinder.DlqSender, Message) | | 0% | | 0% | 20 | 20 | 91 | 91 | 1 | 1 |
| createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties, MessageChannel, MessageChannel) | | 0% | | 0% | 15 | 15 | 54 | 54 | 1 | 1 |
| createPolledConsumerResources(String, String, ConsumerDestination, ExtendedConsumerProperties) | | 0% | | 0% | 10 | 10 | 37 | 37 | 1 | 1 |
| getErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties) | | 0% | | 0% | 7 | 7 | 28 | 28 | 1 | 1 |
| propagateContainerProperties(ContainerProperties) | | 0% | | 0% | 11 | 11 | 24 | 24 | 1 | 1 |
| KafkaMessageChannelBinder(KafkaBinderConfigurationProperties, KafkaTopicProvisioner, ListenerContainerCustomizer, MessageSourceCustomizer, KafkaBindingRebalanceListener, DlqPartitionFunction, DlqDestinationResolver) | | 0% | | n/a | 1 | 1 | 18 | 18 | 1 | 1 |
| getTopicPartitionOffsets(Collection, ExtendedConsumerProperties, ConsumerFactory) | | 0% | | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
| lambda$getPolledConsumerErrorMessageHandler$12(MessageHandler, ExtendedConsumerProperties, Message) | | 0% | | 0% | 7 | 7 | 15 | 15 | 1 | 1 |
| buildMessage(Throwable) | | 0% | | 0% | 7 | 7 | 14 | 14 | 1 | 1 |
| getProducerFactory(String, ExtendedProducerProperties, String, String) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| createBackOff(ExtendedConsumerProperties) | | 0% | | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
| onInit() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| lambda$createConsumerEndpointCaptureHelper$4(DefaultAfterRollbackProcessor, Class, Boolean) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| lambda$getErrorMessageHandler$8(ExtendedConsumerProperties, ConsumerDestination, String, KafkaConsumerProperties, KafkaProducerProperties, KafkaAwareTransactionManager, KafkaMessageChannelBinder.DlqSender, Message) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| lambda$createConsumerEndpointCaptureHelper$3(MessageConverter, AbstractMessageChannelBinder.ErrorInfrastructure, ConsumerRecord, Exception) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| headersToMap(KafkaBinderConfigurationProperties) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| doGetAdditionalConfigurationProperties(String) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| createKafkaConsumerFactory(boolean, String, ExtendedConsumerProperties, String, String) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| setupRebalanceListener(ExtendedConsumerProperties, ContainerProperties) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| getHeaderMapper(ExtendedConsumerProperties) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| resetOffsetsForAutoRebalance(ExtendedConsumerProperties, ConsumerFactory, ContainerProperties) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| expressionInterceptorNeeded(ExtendedProducerProperties) | | 0% | | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
| getPolledConsumerErrorMessageHandler(ConsumerDestination, String, ExtendedConsumerProperties) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$handleRecordForDlq$11(KafkaMessageChannelBinder.DlqSender, AtomicReference, Headers, String, String, Throwable, ExtendedConsumerProperties, MessageHeaders, ConsumerDestination, TransactionStatus) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$createProducerMessageHandler$0(Collection, ChannelInterceptor) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| lambda$createDestResolver$5(Integer, KafkaConsumerProperties, ConsumerRecord, Exception) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
| checkReset(boolean, Object) | | 0% | | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
| getMessageConverter(ExtendedConsumerProperties) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| postProcessOutputChannel(MessageChannel, ExtendedProducerProperties) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| useNativeEncoding(ExtendedProducerProperties) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getStackTraceAsString(Throwable) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| isBatchAndListenerContainerWithDlqAndRetryCustomizer(ExtendedConsumerProperties) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| ensureDlqMessageCanBeProperlySerialized(Map, Predicate, String) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| transactionManager(String) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| isAutoCommitOnError(ExtendedConsumerProperties) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| createDestResolver(KafkaConsumerProperties) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| toDisplayString(String, int) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| lambda$getErrorMessageHandler$7(ConsumerDestination, String, ExtendedConsumerProperties, KafkaConsumerProperties, KafkaProducerProperties, KafkaAwareTransactionManager, KafkaMessageChannelBinder.DlqSender, Message, ConsumerRecord) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$postProcessPollableSource$6(AttributeAccessor, Message) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| determinDlqPartitionFunction(Integer) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| KafkaMessageChannelBinder(KafkaBinderConfigurationProperties, KafkaTopicProvisioner) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| KafkaMessageChannelBinder(KafkaBinderConfigurationProperties, KafkaTopicProvisioner, ListenerContainerCustomizer, KafkaBindingRebalanceListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getTransactionalProducerFactory() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| customizeProducerMessageHandler(MessageHandler, String) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| addClientFactoryCustomizer(ClientFactoryCustomizer) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| addConsumerConfigCustomizer(ConsumerConfigCustomizer) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| addProducerConfigCustomizer(ProducerConfigCustomizer) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| lambda$handleRecordForDlq$10(Map) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| lambda$handleRecordForDlq$9(Map) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$createKafkaConsumerFactory$13(Map, ExtendedConsumerProperties, String, ConsumerConfigCustomizer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getProducerFactory$1(Map, ExtendedProducerProperties, String, ProducerConfigCustomizer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExtendedConsumerProperties(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExtendedProducerProperties(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| createConsumerEndpoint(ConsumerDestination, String, ExtendedConsumerProperties) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties, MessageChannel) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setExtendedBindingProperties(KafkaExtendedBindingProperties) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setProducerListener(ProducerListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setRebalanceListener(KafkaBindingRebalanceListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setDlqPartitionFunction(DlqPartitionFunction) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| setDlqDestinationResolver(DlqDestinationResolver) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getDefaultsPrefix() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExtendedPropertiesEntryClass() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBinderIdentity() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| postProcessPollableSource(DefaultPollableMessageSource) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getErrorMessageStrategy() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getKafkaMessageListenerContainers() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$createKafkaConsumerFactory$14(DefaultKafkaConsumerFactory, ClientFactoryCustomizer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getProducerFactory$2(DefaultKafkaProducerFactory, ClientFactoryCustomizer) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTopicsInUse() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |