WIP

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index c6798f157667ae572c7eddf4a0c5ce24efa4844a..f8bf8576eb6b0ae99f12699c373a3f00bebaf29d 100644 (file)
--- 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 d54a5bb481afda36f82889a6b6350d4c12405948..753debe2b00344766c2c9a4f90286e0b6e075337 100644 (file)
--- 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();
+    }
        }
 }