mguenther/kafka-junit

Typo in sample test case shouldWaitForRecordsToBePublished form readme

vaibhav-b opened this issue · 2 comments

vaibhav-b commented

Typo in 1st example present in readme of kafka-junit. Test case failing.

Please update kafka.observe(on("test-topic", 3)) in readme.

@Test
    void shouldWaitForRecordsToBePublished() throws Exception {
        kafka.send(to("test-topic", "a", "b", "c"));
        kafka.observe(on("test-topic", 4));
    }
mguenther commented

Thanks for bringing this to my attention!

mguenther commented

Only affects README.md - fixed now.