From: Kai Moritz <kai@juplo.de>
Date: Wed, 17 Aug 2022 20:51:10 +0000 (+0200)
Subject: ROT: Korrigierten/Verbesserten Test und Überarbeitetes Setup gemerged
X-Git-Tag: sumup-adder---lvm-2-tage~10
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=d2eb370acf1a2195c36421ffc471f67cb4a8e86e;p=demos%2Fkafka%2Ftraining

ROT: Korrigierten/Verbesserten Test und Überarbeitetes Setup gemerged

* 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.
---

d2eb370acf1a2195c36421ffc471f67cb4a8e86e
diff --cc src/test/java/de/juplo/kafka/GenericApplicationTests.java
index 9a6f812,93daf6b..b019373
--- a/src/test/java/de/juplo/kafka/GenericApplicationTests.java
+++ b/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;
@@@ -329,6 -324,6 +332,7 @@@
  		props.put("value.deserializer", BytesDeserializer.class.getName());
  		offsetConsumer = new KafkaConsumer<>(props);
  
++		mongoClient.getDatabase(mongoProperties.getDatabase()).drop();
  		seekToEnd();
  
  		oldOffsets = new HashMap<>();