Skip to content

Commit f7cabca

Browse files
bistrosartembilan
authored andcommitted
Fix KafkaEmbedded sample in Docs
1 parent 51c84c4 commit f7cabca

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/reference/asciidoc/testing.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -117,11 +117,11 @@ For convenience a test class level `@EmbeddedKafka` annotation is provided with
117117
public class KafkaStreamsTests {
118118
119119
@Autowired
120-
private KafkaEmbedded kafkaEmbedded;
120+
private KafkaEmbedded embeddedKafka;
121121
122122
@Test
123123
public void someTest() {
124-
Map<String, Object> consumerProps = KafkaTestUtils.consumerProps("testGroup", "true", this.kafkaEmbedded);
124+
Map<String, Object> consumerProps = KafkaTestUtils.consumerProps("testGroup", "true", this.embeddedKafka);
125125
consumerProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
126126
ConsumerFactory<Integer, String> cf = new DefaultKafkaConsumerFactory<>(consumerProps);
127127
Consumer<Integer, String> consumer = cf.createConsumer();

0 commit comments

Comments
 (0)