spring-kafka-test Examples and Free Source Code

How to test Kafka Consumer with @KafkaListener and Mockito?...

spring-boot apache-kafka spring-kafka-test

Embedded Kafka Test - The Kafka listener is not invoked...

spring-boot apache-kafka spring-kafka spring-kafka-test

Testing Spring Kafka Listener in Spring Boot Test with EmbeddedKafka...

spring-kafka spring-kafka-test

Embedded kafka in tests with JUnit failing when running all tests...

spring-boot mockito junit5 spring-boot-test spring-kafka-test

Embedded Kafka tests randomly failing...

apache-kafka spring-kafka spring-kafka-test

KafkaListener Not triggered in Spring Boot test...

spring-boot apache-kafka spring-kafka spring-kafka-test testcontainers-junit5

Parallelly running Embedded Kafka spring boot tests...

spring spring-boot spring-kafka junit5 spring-kafka-test

Test Kafka consumer using EmbddedKafka fail when launching a batch of tests...

spring-boot apache-kafka spring-kafka spring-kafka-test embedded-kafka

Numbers of partitions during EmbeddedKafka tests with multiple topics...

spring-boot apache-kafka kafka-consumer-api spring-kafka spring-kafka-test

Kafka Streams Testing : java.util.NoSuchElementException: Uninitialized topic: "output_topic_na...

unit-testing apache-kafka apache-kafka-streams kafka-topic spring-kafka-test

transaction-id-prefix need to be identical for same application instance in spring kafka 3?...

apache-kafka spring-kafka spring-kafka-test kafka-transactions-api

Facing issue in Connecting Kafka 3.0 - org.apache.kafka.common.KafkaException: Failed to load SSL ke...

apache-kafka spring-kafka apache-kafka-connect spring-kafka-test

Could not complete execution for Gradle Test Executor Spring Boot 3.0...

spring-boot kotlin gradle spring-kafka spring-kafka-test

spring kafka properties not auto loaded when writing customConsumerFactory and customKafkaListenerCo...

java spring-boot apache-kafka spring-kafka-test

KafkaMessageChannelBinder cannot be cast to class TestSupportBinder...

spring-boot spring-cloud-stream spring-cloud-stream-binder-kafka spring-kafka-test

Missing dependency on EmbeddedKafka on integration test with groovy and spock...

java spring-boot gradle spring-kafka spring-kafka-test

How to test Kafka OnFailure callback with Junit?...

junit apache-kafka mockito spring-kafka spring-kafka-test

Embedded Kafka starting with wrong number of partitions...

java spring-boot apache-kafka spring-kafka spring-kafka-test

EmbeddedKafka failing since Spring Boot 2.6.X : AccessDeniedException: ..\AppData\Local\Temp\spring....

spring-kafka spring-kafka-test

Tests fail to start using spring-kafka-test (NoClassDefFoundError)...

spring spring-boot apache-kafka spring-kafka spring-kafka-test

KafkaTestUtils.getRecords() or KafkaTestUtils.getSingleRecord() takes too long some times...

java spring-kafka spring-kafka-test

how to set adminTimeout value with @EmbeddedKafka Annotation (junit5)?...

spring-kafka spring-kafka-test

Spring KafkaTestUtils: wait until message in topic would be consumed...

java spring-boot integration-testing spring-boot-test spring-kafka-test

Upgrading to Spring boot to 2.5.5 creates issue with kafka libraries...

spring-boot apache-kafka jar spring-kafka spring-kafka-test

How to send a message with specific offset to EmbeddedKafka in spring boot?...

spring-boot apache-kafka spring-kafka spring-kafka-test embedded-kafka

Spring boot embedded kafka throws error BeanCreationException...

apache-kafka spring-kafka spring-kafka-test

How do I spin up an embedded kafka cluster during my test?...

java junit apache-kafka spring-kafka spring-kafka-test

ClassNotFoundException: scala.collection.convert.AsJavaExtensions when using @EmbeddedKafka from spr...

spring-boot kotlin gradle spring-kafka spring-kafka-test

Null point exception on embedded Kafka...

java spring-kafka spring-kafka-test reactive-kafka

Kafka transactional producer throws 'Timeout expired while initializing transactional state in 6...

java apache-kafka spring-kafka spring-transactions spring-kafka-test