ROT: Verbesserungen aus 'deserialization' in 'sumup-adder' gemerged
authorKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 16:09:17 +0000 (18:09 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 16:09:17 +0000 (18:09 +0200)
commitc9d7601fc551069cd3a77da06a6333f22101a8a0
treec6b88ebadedec8bd9c4adda19b5028faf04b9249
parent3e6248a8f09479abc38cf9396602ec2e26e473c5
parent4b19a0061b88863c015424088f429b6998557dc8
ROT: Verbesserungen aus 'deserialization' in 'sumup-adder' gemerged

* Dabei: Die Verbesserungen aus 'deserialization' genutzt, um in
  `ApplicationTests` einen angepassten `RecordGenerator` zu
  implementieren.
* Da der Service derzeit mit `String` für Schlüssel und Nachricht
  arbeitet, kann keine Poison-Pill erzeugt werden (null-Nachrichten
  führen nicht zu einer `DeserializationException` und alles andere
  lässt sich in einen - fachlich ggf. sinnfreien - String konvertieren).
* Der Test für Logik-Fehler schlägt fehl, weil er einen Fehler in der
  Implementierung aufdeckt!
* Alle bisherigen Versionen von `EndlessConsumer`, die ihre Offsets in
  der Mongo-DB mit speichern führen bei einer `DeserializationException`
  einen Offset-Commit durch, wenn ihnen durch das darauf folgende
  `unsubscribe()` die Partitionen entzogen werden.
* D.h., bisher wurden in dieser Situation Nachrichten verloren!
pom.xml
src/test/java/de/juplo/kafka/ApplicationTests.java
src/test/java/de/juplo/kafka/GenericApplicationTests.java