]> juplo.de Git - demos/kafka/training/commitdiff
Verbesserte/Erweiterte Tests aus 'stored-offsets' nach 'wordcount' gemerged
authorKai Moritz <kai@juplo.de>
Sat, 13 Aug 2022 09:44:13 +0000 (11:44 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 13 Aug 2022 09:54:39 +0000 (11:54 +0200)
1  2 
src/test/java/de/juplo/kafka/ApplicationTests.java

index f4c21041bf7c8febdb1b14abc77efc96c1be139b,fc5d4c9e51d21348a9271fad7877bbd07b9ed0fe..aa3dfd64efd1abcb923c3891745e9d2ea2354f44
@@@ -61,8 -60,10 +59,10 @@@ class ApplicationTest
        @Autowired
        KafkaProducer<String, Bytes> kafkaProducer;
        @Autowired
 -      KafkaConsumer<String, Long> kafkaConsumer;
 +      KafkaConsumer<String, String> kafkaConsumer;
        @Autowired
+       KafkaConsumer<Bytes, Bytes> offsetConsumer;
+       @Autowired
        PartitionStatisticsRepository partitionStatisticsRepository;
        @Autowired
        ApplicationProperties properties;