X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=1781b1d04c5866e838a8a9d399f70eb568295995;hb=ccc0bbf53e09e7154e96958957e78f94a9d11ead;hp=1e730405e93d7f64f22ca1f8127e3ff3bff25e3a;hpb=4bff99449827596fd62a16165da42225d5956804;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 1e73040..1781b1d 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -1,16 +1,13 @@
 package de.juplo.kafka;
 
-import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.LongSerializer;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.apache.kafka.common.utils.Bytes;
 import org.springframework.boot.test.context.TestConfiguration;
 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;
 
 
@@ -73,9 +70,8 @@ public class ApplicationTests extends GenericApplicationTests<String, Long>
   @TestConfiguration
   public static class Configuration
   {
-    @Primary
     @Bean
-    public Consumer<ConsumerRecord<String, Long>> consumer()
+    public RecordHandler<String, Long> recordHandler()
     {
       return (record) ->
       {