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

@@@ -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;