diff --git a/src/reference/asciidoc/quick-tour.adoc b/src/reference/asciidoc/quick-tour.adoc index d8e80d70..e225854b 100644 --- a/src/reference/asciidoc/quick-tour.adoc +++ b/src/reference/asciidoc/quick-tour.adoc @@ -131,8 +131,8 @@ private KafkaTemplate template; @Test public void testSimple() throws Exception { - waitListening("foo"); template.send("annotated1", 0, "foo"); + template.flush(); assertTrue(this.listener.latch1.await(10, TimeUnit.SECONDS)); }