From c700cf28cce44c33ed38de5012f271d349f788bc Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Wed, 21 Dec 2016 15:00:39 -0800 Subject: [PATCH] Fix typo in Kafka sample --- .../kafka/KafkaSpecialProducerConsumerConfigExample.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/spring-boot-docs/src/main/java/org/springframework/boot/kafka/KafkaSpecialProducerConsumerConfigExample.java b/spring-boot-docs/src/main/java/org/springframework/boot/kafka/KafkaSpecialProducerConsumerConfigExample.java index 23a7aa139d6..93c1f84b89c 100644 --- a/spring-boot-docs/src/main/java/org/springframework/boot/kafka/KafkaSpecialProducerConsumerConfigExample.java +++ b/spring-boot-docs/src/main/java/org/springframework/boot/kafka/KafkaSpecialProducerConsumerConfigExample.java @@ -64,11 +64,10 @@ public class KafkaSpecialProducerConsumerConfigExample { */ @Bean public ConsumerFactory kafkaConsumerFactory(KafkaProperties properties) { - Map consumererProperties = properties - .buildConsumerProperties(); - consumererProperties.put(CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG, + Map consumerProperties = properties.buildConsumerProperties(); + consumerProperties.put(CommonClientConfigs.METRIC_REPORTER_CLASSES_CONFIG, MyConsumerMetricsReporter.class); - return new DefaultKafkaConsumerFactory(consumererProperties); + return new DefaultKafkaConsumerFactory(consumerProperties); } }