projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 0e0f30e) | patch
Tests: Der Test wartet, bis die Offsets regulär committed wurden
authorKai Moritz <kai@juplo.de>
Mon, 11 Apr 2022 07:41:40 +0000 (09:41 +0200)
committerKai Moritz <kai@juplo.de>
Mon, 11 Apr 2022 13:23:50 +0000 (15:23 +0200)
commitb7d02b89c884eeaf864e5c86c30c7313a7b1036e
tree6615bb534fc127070a31f158487a1a21e0ac9da0tree | snapshot
parent0e0f30edc9bdcd230db1e7f4cbe414f85d5d288acommit | diff
Tests: Der Test wartet, bis die Offsets regulär committed wurden

* Zuvor wurde der Offset-Commit erzwungen, indem der EndlessConsumer
  über den Aufruf von `stop()` beendet wurde.
* Jetzt wird die Überprüfung der Erwartungen über awaitility aufgeschoben,
  bis die Erwartungen beobachtet werden können - oder eine Zeitschranke
  gerissen wird.
src/test/java/de/juplo/kafka/ApplicationTests.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.