From: Kai Moritz <kai@juplo.de>
Date: Sat, 10 Sep 2022 06:48:57 +0000 (+0200)
Subject: WIP
X-Git-Tag: wip-kafka-handler~5
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=4255cc641e2b4d2e0b06cc6f7bd46d1721eb1559;p=demos%2Fkafka%2Ftraining

WIP
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index c6798f1..f8bf857 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -66,10 +66,4 @@ public class ApplicationConfiguration
             errorHandler,
             recordHandler);
   }
-
-  @Bean
-  public ApplicationErrorHandler applicationErrorHandler()
-  {
-    return new ApplicationErrorHandler();
-  }
 }
diff --git a/src/test/java/de/juplo/kafka/GenericApplicationTests.java b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
index d54a5bb..753debe 100644
--- a/src/test/java/de/juplo/kafka/GenericApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/GenericApplicationTests.java
@@ -392,5 +392,11 @@ abstract class GenericApplicationTests<K, V>
 		{
 			return new TestRecordHandler(applicationRecordHandler);
 		}
+
+    @Bean(destroyMethod = "close")
+    public org.apache.kafka.clients.consumer.Consumer<String, Message> kafkaConsumer(ConsumerFactory<String, Message> factory)
+    {
+      return factory.createConsumer();
+    }
 	}
 }