Fixed error handler name

vsadokhin · Oct 1, 2018 · 847fcfa · 847fcfa
1 parent 45b7525
commit 847fcfa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/stream-consumer/src/main/java/me/vsadokhin/iot/stream/consumer/KafkaConsumer.java b/stream-consumer/src/main/java/me/vsadokhin/iot/stream/consumer/KafkaConsumer.java
@@ -18,7 +18,7 @@ public KafkaConsumer(MetricRepository metricRepository) {
         this.metricRepository = metricRepository;
     }
 
-    @KafkaListener(id = "metric-listener", topics = "metric", groupId = "stream", errorHandler = "metricListenerErrorHandler")
+    @KafkaListener(id = "metric-listener", topics = "metric", groupId = "stream", errorHandler = "errorHandler")
     public void processMessage(Metric metric, Acknowledgment acknowledgment) {
         for (MetricTable metricTable : MetricTable.values()) {
             metricRepository.insert(metric, metricTable);