From f7cabcafb4d0b2be218b04076afd9bd96e0192d4 Mon Sep 17 00:00:00 2001 From: bistros Date: Thu, 11 Jan 2018 00:25:01 +0900 Subject: [PATCH] Fix KafkaEmbedded sample in Docs --- src/reference/asciidoc/testing.adoc | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/reference/asciidoc/testing.adoc b/src/reference/asciidoc/testing.adoc index bc126c2c..cc54ef61 100644 --- a/src/reference/asciidoc/testing.adoc +++ b/src/reference/asciidoc/testing.adoc @@ -117,11 +117,11 @@ For convenience a test class level `@EmbeddedKafka` annotation is provided with public class KafkaStreamsTests { @Autowired - private KafkaEmbedded kafkaEmbedded; + private KafkaEmbedded embeddedKafka; @Test public void someTest() { - Map consumerProps = KafkaTestUtils.consumerProps("testGroup", "true", this.kafkaEmbedded); + Map consumerProps = KafkaTestUtils.consumerProps("testGroup", "true", this.embeddedKafka); consumerProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); ConsumerFactory cf = new DefaultKafkaConsumerFactory<>(consumerProps); Consumer consumer = cf.createConsumer();