diff --git a/src/reference/asciidoc/quick-tour.adoc b/src/reference/asciidoc/quick-tour.adoc index 69f0785d..d8e80d70 100644 --- a/src/reference/asciidoc/quick-tour.adoc +++ b/src/reference/asciidoc/quick-tour.adoc @@ -44,7 +44,6 @@ Using plain Java to send and receive a message: public void testAutoCommit() throws Exception { logger.info("Start auto"); ContainerProperties containerProps = new ContainerProperties("topic1", "topic2"); - KafkaMessageListenerContainer container = createContainer(containerProps); final CountDownLatch latch = new CountDownLatch(4); containerProps.setMessageListener(new MessageListener() { @@ -55,6 +54,7 @@ public void testAutoCommit() throws Exception { } }); + KafkaMessageListenerContainer container = createContainer(containerProps); container.setBeanName("testAuto"); container.start(); Thread.sleep(1000); // wait a bit for the container to start