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();