projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 2776804) | patch
Signatur und Handling des `RecordGenerator` vereinfacht/überarbeitet
authorKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 13:35:28 +0000 (15:35 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 14 Aug 2022 16:03:59 +0000 (18:03 +0200)
commit1288af99aeb350661f8b0a60762cba8e1b0f6a24
tree7071cf9a9c785a344b85ea9217e561d76f12a3aatree | snapshot
parent27768041f2c2f4b1cbb8c45c9a5d665490050f76commit | diff
Signatur und Handling des `RecordGenerator` vereinfacht/überarbeitet

* Der `RecordGenerator` darf jetzt selbst bestimmen, wie viele Nachrichten
  er erzeugt und wo wieviele Poison-Pills oder Logik-Fehler erzeugt
  werden, wenn der Test dies anfordert.
* Dafür git der `RecordGenerator` jetzt die Anzahl der tatsächlich
  erzeugten Nachrichten zurück, damit die Tests richtig reagieren können.
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
src/test/java/de/juplo/kafka/ErrorCannotBeGeneratedCondition.java diff | blob | history
src/test/java/de/juplo/kafka/GenericApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.