How to integrate kafkaunit with spring

[ashishsoni]

No description provided.

[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);
}