Der Test verwendet die `@Bean` von `EndlessConsumer`

[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 1781b1d..b7f8308 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -71,7 +71,7 @@ public class ApplicationTests extends GenericApplicationTests<String, Long>
   public static class Configuration
   {
     @Bean
-    public RecordHandler<String, Long> recordHandler()
+    public RecordHandler<String, Long> applicationRecordHandler()
     {
       return (record) ->
       {