ROT: Korrigierten/Verbesserten Test und Überarbeitetes Setup gemerged
authorKai Moritz <kai@juplo.de>
Wed, 17 Aug 2022 20:51:10 +0000 (22:51 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 19 Aug 2022 09:49:19 +0000 (11:49 +0200)
* Merge branch 'sumup-adder--ohne--stored-offsets' into sumup-adder.
* In dem gemergten Branch ist es nicht wichtig, wann genau die
  Mongo-DB zwischen den Tests zurückgesetzt wird, da sie nur den Zustand
  des Consumers enthält.
* Wenn die Offsets mit in der Mongo-DB gespeichert werden, ist es
  wesentlich, an zu welchem Zeitpunkt während der Test-Vorbereitung
  diese zurückgesetzt wird!
* ROT: Der verbesserte/verschärfte Test deckt Fehler in der Test-Logik auf.

1  2 
src/test/java/de/juplo/kafka/GenericApplicationTests.java

@@@ -60,8 -62,10 +62,12 @@@ abstract class GenericApplicationTests<
        @Autowired
        ExecutorService executor;
        @Autowired
 +      StateRepository stateRepository;
 +      @Autowired
+       MongoClient mongoClient;
+       @Autowired
+       MongoProperties mongoProperties;
+       @Autowired
        PollIntervalAwareConsumerRebalanceListener rebalanceListener;
        @Autowired
        RecordHandler<K, V> recordHandler;
                props.put("value.deserializer", BytesDeserializer.class.getName());
                offsetConsumer = new KafkaConsumer<>(props);
  
++              mongoClient.getDatabase(mongoProperties.getDatabase()).drop();
                seekToEnd();
  
                oldOffsets = new HashMap<>();