From 4255cc641e2b4d2e0b06cc6f7bd46d1721eb1559 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 10 Sep 2022 08:48:57 +0200
Subject: [PATCH] WIP

---
 src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 6 ------
 src/test/java/de/juplo/kafka/GenericApplicationTests.java  | 6 ++++++
 2 files changed, 6 insertions(+), 6 deletions(-)

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();
+    }
 	}
 }
-- 
2.20.1