How to integrate kafkaunit with spring

[ashishsoni]

[jacobbeasley]

It works for me as-is. I just add it as a rule as part of Spring Boot integration test (@WebIntegrationTest) and it works.

[jacobbeasley]

@RunWith(SpringJUnit4ClassRunner.class) @WebIntegrationTest public class SomeTest { @Rule public KafkaUnitRule kafkaUnitRule = new KafkaUnitRule(2181, 9092); }