Sample project to show how to implement Integration Test in Spring Boot. With Spring Kafka and EmbeddedKafka.

Example with Spring Boot 2.2.6 (Spring Kafka 2.4.5)

• ConsumerServiceIntegrationTest.java
• ProducerServiceIntegrationTest.java

Official Example : github.com/spring-projects/spring-kafka

To write integration tests you can also have a look at :

• github.com/authorjapps/zerocode
• github.com/authorjapps/zerocode/tree/master/kafka-testing