| testDlqGuts(boolean, HeaderMode, Integer, boolean, boolean, boolean, boolean) |  | 0% | | 0% | 21 | 21 | 161 | 161 | 1 | 1 |
| testSendAndReceiveWithMixedMode() | | 0% | | n/a | 1 | 1 | 79 | 79 | 1 | 1 |
| testPartitionedModuleSpEL(TestInfo) | | 0% | | 0% | 2 | 2 | 71 | 71 | 1 | 1 |
| partitionedModuleJava() | | 0% | | 0% | 2 | 2 | 64 | 64 | 1 | 1 |
| partitionedModuleSpELWithRawMode() | | 0% | | n/a | 1 | 1 | 57 | 57 | 1 | 1 |
| testInternalHeadersNotPropagatedGuts(String, String[], KafkaHeaderMapper) | | 0% | | 0% | 4 | 4 | 56 | 56 | 1 | 1 |
| partitionedModuleJavaWithRawMode() | | 0% | | n/a | 1 | 1 | 47 | 47 | 1 | 1 |
| resume() | | 0% | | 0% | 3 | 3 | 53 | 53 | 1 | 1 |
| testAnonymousGroup(TestInfo) | | 0% | | n/a | 1 | 1 | 51 | 51 | 1 | 1 |
| configurableDlqName() | | 0% | | n/a | 1 | 1 | 55 | 55 | 1 | 1 |
| defaultAutoCommitOnErrorWithDlq() | | 0% | | n/a | 1 | 1 | 52 | 52 | 1 | 1 |
| autoCommitOnErrorWhenManualAcknowledgement() | | 0% | | n/a | 1 | 1 | 52 | 52 | 1 | 1 |
| resetOffsets() | | 0% | | 0% | 3 | 3 | 40 | 40 | 1 | 1 |
| testSendAndReceiveBatch() | | 0% | | 0% | 2 | 2 | 43 | 43 | 1 | 1 |
| testDlqWithNativeSerializationEnabledOnDlqProducer() | | 0% | | n/a | 1 | 1 | 48 | 48 | 1 | 1 |
| testSendAndReceiveMultipleTopics(TestInfo) | | 0% | | n/a | 1 | 1 | 45 | 45 | 1 | 1 |
| testSendAndReceive(TestInfo) | | 0% | | n/a | 1 | 1 | 43 | 43 | 1 | 1 |
| earliest() | | 0% | | 0% | 3 | 3 | 43 | 43 | 1 | 1 |
| producerErrorChannel() | | 0% | | n/a | 1 | 1 | 33 | 33 | 1 | 1 |
| nativeSerializationWithCustomSerializerDeserializerBytesPayload() | | 0% | | 0% | 3 | 3 | 42 | 42 | 1 | 1 |
| defaultConsumerStartsAtEarliest() | | 0% | | n/a | 1 | 1 | 37 | 37 | 1 | 1 |
| testSendAndReceiveBatchWithDlqEnabled() | | 0% | | n/a | 1 | 1 | 39 | 39 | 1 | 1 |
| customHeaderMapper() | | 0% | | n/a | 1 | 1 | 36 | 36 | 1 | 1 |
| defaultHeaderMapper() | | 0% | | n/a | 1 | 1 | 37 | 37 | 1 | 1 |
| wellKnownHeaderMapperWithBeanNameKafkaHeaderMapper() | | 0% | | n/a | 1 | 1 | 35 | 35 | 1 | 1 |
| testTwoRequiredGroups(TestInfo) | | 0% | | n/a | 1 | 1 | 31 | 31 | 1 | 1 |
| testDlqWithProducerPropertiesSetAtBinderLevel() | | 0% | | n/a | 1 | 1 | 39 | 39 | 1 | 1 |
| compression() | | 0% | | 0% | 2 | 2 | 28 | 28 | 1 | 1 |
| testDlqWithNativeDecodingOnConsumerButMissingSerializerOnDlqProducer() | | 0% | | n/a | 1 | 1 | 37 | 37 | 1 | 1 |
| nativeSerializationWithCustomSerializerDeserializer() | | 0% | | 0% | 3 | 3 | 33 | 33 | 1 | 1 |
| dynamicPartitionUpdates() | | 0% | | n/a | 1 | 1 | 32 | 32 | 1 | 1 |
| commonErrorHandlerBeanNameOnConsumerBinding() | | 0% | | n/a | 1 | 1 | 32 | 32 | 1 | 1 |
| builtinSerialization() | | 0% | | 0% | 3 | 3 | 33 | 33 | 1 | 1 |
| polledConsumer() | | 0% | | 0% | 5 | 5 | 31 | 31 | 1 | 1 |
| polledConsumerWithDlq() | | 0% | | 0% | 2 | 2 | 30 | 30 | 1 | 1 |
| testSendAndReceiveNoOriginalContentType(TestInfo) | | 0% | | n/a | 1 | 1 | 28 | 28 | 1 | 1 |
| autoCreateTopicsDisabledOnBinderStillWorksAsLongAsBrokerCreatesTopic() | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| consumerCustomDeserializer() | | 0% | | 0% | 2 | 2 | 29 | 29 | 1 | 1 |
| dynamicKeyExpression() | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| testSendAndReceiveWithRawMode() | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| customPartitionCountDoesNotOverridePartitioningIfSmaller() | | 0% | | n/a | 1 | 1 | 28 | 28 | 1 | 1 |
| autoAddPartitionsDisabledSucceedsIfTopicPartitionedCorrectly() | | 0% | | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
| customPartitionCountOverridesDefaultIfLarger() | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| recordMetadata() | | 0% | | 0% | 2 | 2 | 23 | 23 | 1 | 1 |
| customPartitionCountOverridesPartitioningIfLarger() | | 0% | | n/a | 1 | 1 | 27 | 27 | 1 | 1 |
| topicPatterns() | | 0% | | n/a | 1 | 1 | 24 | 24 | 1 | 1 |
| retriesWithoutDlq() | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| bindersAdmin() | | 0% | | n/a | 1 | 1 | 22 | 22 | 1 | 1 |
| consumerDefaultDeserializer() | | 0% | | 0% | 2 | 2 | 25 | 25 | 1 | 1 |
| manualAckSucceedsWhenAutoCommitOffsetIsTurnedOff() | | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
| partitionedNative() | | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
| manualAckIsNotPossibleWhenAutoCommitOffsetIsEnabledOnTheBinder() | | 0% | | n/a | 1 | 1 | 23 | 23 | 1 | 1 |
| polledConsumerRequeue() | | 0% | | 0% | 3 | 3 | 19 | 19 | 1 | 1 |
| noBrokerOverride() | | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
| sendTimeoutExpressionProducerMetadata() | | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
| messageKeyInPayload() | | 0% | | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
| autoAddPartitionsDisabledSucceedsIfTopicUnderPartitionedAndAutoRebalanceEnabled() | | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
| autoAddPartitionsDisabledFailsIfTopicUnderPartitionedAndAutoRebalanceDisabled() | | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
| syncProducerMetadata() | | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
| sameTopicCannotBeProvisionedAgain() | | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
| partitionCountNotReduced() | | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
| allowNonTransactionalProducerSetting() | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| assertionsOnKafkaTemplate(TestObservationRegistry, Binding) | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| partitionCountIncreasedIfAutoAddPartitionsSet() | | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| consumerFactory() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| autoConfigureTopicsDisabledSucceedsIfTopicExisting() | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| setupBindingAndAssert(String, AbstractKafkaTestBinder) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| getBinder() | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| autoCreateTopicsEnabledSucceeds() | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| lambda$testSendAndReceiveMultipleTopics$24(Message) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getBinder(KafkaBinderConfigurationProperties, DlqPartitionFunction, DlqDestinationResolver) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| init() | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| invokePartitionSize(String) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| createConfigurationProperties() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| invokeCreateTopic(String, int, int) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| lambda$testDlqGuts$20(AtomicReference, AtomicBoolean, AtomicBoolean, Message) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| createConsumerProperties() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| internalHeadersNotPropagatedCustomHeader() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| observationEnabledOnTheBinder() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| observationEnabledThroughProducerMessageHandlerCustomizer() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| createProducerProperties(TestInfo) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| internalHeadersNotPropagatedCustomMapper() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$resetOffsets$50(DirectChannel, String, int) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$autoAddPartitionsDisabledFailsIfTopicUnderPartitionedAndAutoRebalanceDisabled$39(Binder, String, DirectChannel, ExtendedConsumerProperties) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$testPartitionedModuleSpEL$25(AtomicInteger, ChannelInterceptor) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| lambda$testDlqGuts$19(boolean) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| lambda$testDlqWithNativeSerializationEnabledOnDlqProducer$15(KafkaBinderTests.FailingInvocationCountingMessageHandler, ExtendedConsumerProperties) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$resetOffsets$51(AtomicReference, AtomicInteger, CountDownLatch, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| lambda$topicPatterns$49(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$polledConsumerRequeue$46(Message) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryWithNonRetryableException() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryDefaultFalse() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryDefaultFalseWithRetryableException() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryWithNonRetryableExceptionTransactional() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryDefaultFalseTransactional() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryDefaultFalseWithRetryableExceptionTransactional() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testDlqGuts(boolean, HeaderMode, Integer, boolean, boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlq() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqWithDlqDestinationResolver() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqTransactional() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqNone() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqEmbedded() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetry() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| dlqAndRetryTransactional() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| validateKafkaTopicName() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| lambda$noBrokerOverride$56(Binder, DirectChannel, ExtendedConsumerProperties) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$noBrokerOverride$55(Binder, DirectChannel, BindingProperties) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$polledConsumerRequeue$47(Message) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$polledConsumer$44(Message) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$polledConsumer$42(Message) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$testSendAndReceiveBatch$13(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| KafkaBinderTests() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| partitionSize(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$polledConsumer$43(Message) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$polledConsumer$41(Message) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getBinder(KafkaBinderConfigurationProperties) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| internalHeadersNotPropagated() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$builtinSerialization$40(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$autoCreateTopicsDisabledOnBinderStillWorksAsLongAsBrokerCreatesTopic$38(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$resume$37(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$resume$36(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$resume$35(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$defaultConsumerStartsAtEarliest$34(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$defaultConsumerStartsAtEarliest$33(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$producerErrorChannel$31(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$testSendAndReceiveWithRawMode$30(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$earliest$23(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$earliest$22(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$compression$21(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$testDlqGuts$17(Integer, String, ConsumerRecord, Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testSendAndReceive$11(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$testSendAndReceiveNoOriginalContentType$9(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$wellKnownHeaderMapperWithBeanNameKafkaHeaderMapper$8(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$customHeaderMapper$5(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$defaultHeaderMapper$2(AtomicReference, CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| spyOn(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$observationEnabledThroughProducerMessageHandlerCustomizer$57(KafkaProducerMessageHandler, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$polledConsumerWithDlq$48(Message) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$wellKnownHeaderMapperWithBeanNameKafkaHeaderMapper$7() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$customHeaderMapper$4() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| createProducerProperties() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$partitionedModuleJavaWithRawMode$29() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$partitionedModuleJavaWithRawMode$28() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$partitionedModuleJava$27() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$partitionedModuleJava$26() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setup() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| binderBindUnbindLatency() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getClassUnderTestName() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$producerErrorChannel$32(CountDownLatch, Message) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testDlqGuts$16(String, ConsumerRecord, Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getKafkaOffsetHeaderKey() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| usesExplicitRouting() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testInternalHeadersNotPropagatedGuts$54(KafkaHeaderMapper) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$recordMetadata$52(QueueChannel) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testDlqGuts$18(ConsumerRecord, Exception) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testSendAndReceiveBatchWithDlqEnabled$14(BatchMessagingMessageConverter) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testSendAndReceiveBatch$12(BatchMessagingMessageConverter) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testSendAndReceive$10(MessagingMessageConverter) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testInternalHeadersNotPropagatedGuts$53(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$polledConsumer$45(Message) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$wellKnownHeaderMapperWithBeanNameKafkaHeaderMapper$6(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$customHeaderMapper$3(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getBinder$1(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getBinder$0(Map) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |