X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=b7f8308e601b46beb3b0f81219a956c34f537f68;hb=66f52b33cb2380a7449ba6135f1b94a7bbe4d57d;hp=1781b1d04c5866e838a8a9d399f70eb568295995;hpb=ccc0bbf53e09e7154e96958957e78f94a9d11ead;p=demos%2Fkafka%2Ftraining diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index 1781b1d..b7f8308 100644 --- 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 public static class Configuration { @Bean - public RecordHandler recordHandler() + public RecordHandler applicationRecordHandler() { return (record) -> {