X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=516622747d135c5c93a89c711ac2a46ea976ec2c;hb=f1eec82fb197f9fc7906eb9a90d75468e9e4356f;hp=8369a7b97d5755e4365db37ac4f359247939f223;hpb=1288af99aeb350661f8b0a60762cba8e1b0f6a24;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 8369a7b..5166227 100644 --- a/src/test/java/de/juplo/kafka/ApplicationTests.java +++ b/src/test/java/de/juplo/kafka/ApplicationTests.java @@ -10,7 +10,6 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Primary; import org.springframework.test.context.ContextConfiguration; -import java.util.Set; import java.util.function.Consumer; @@ -75,12 +74,18 @@ public class ApplicationTests extends GenericApplicationTests { @Primary @Bean - public Consumer> consumer() + public ApplicationRecordHandler recordHandler() { - return (record) -> + ApplicationRecordHandler recordHandler = new ApplicationRecordHandler(); + return new ApplicationRecordHandler() { - if (record.value() == Long.MIN_VALUE) - throw new RuntimeException("BOOM (Logic-Error)!"); + @Override + public void accept(ConsumerRecord record) + { + if (record.value() == Long.MIN_VALUE) + throw new RuntimeException("BOOM (Logic-Error)!"); + super.accept(record); + } }; } }