juplo.de Git - demos/kafka/training/commit

author	Kai Moritz <kai@juplo.de>
	Sun, 24 Jul 2022 13:35:14 +0000 (15:35 +0200)
committer	Kai Moritz <kai@juplo.de>
	Fri, 12 Aug 2022 14:44:01 +0000 (16:44 +0200)
commit	e53004f3133b737699e995a3b18fff28203a0e8c
tree	35b60a7e83af293dea1296a4ca79a3c26a99c165	tree \| snapshot
parent	7d46d2df2b323e0f4df2e7b5f15706840de4b804	commit \| diff
parent	83a4bf324f5a7ec6010a7921118ec7d6e8f997cf	commit \| diff

Merge der Refaktorisierung des EndlessConsumer (Branch 'stored-state')

* Die `commtSync()`-Aufrufe machen beim Speichern der Offsets außerhalb
  von Kafka keinen Sinn mehr.
* Der Testfall musste an die extern gespeicherten Offsets angepasst
  werden: Die gesehenen Offsets müssen aus der MongoDB gelesen werden,
  anstatt über einen separaten Consumer aus Kafka.
* Der mit dem Merge hinzugefügte Test schlägt fehl, da er einen Fehler
  aufdeckt (NPE bei einer Log-Ausgabe zur Offset-Verarbeitung).

docker-compose.yml	diff1 \|	diff2 \|	blob \| history
src/main/java/de/juplo/kafka/ApplicationConfiguration.java	\|	diff2 \|	blob \| history
src/main/java/de/juplo/kafka/EndlessConsumer.java	diff1 \|	diff2 \|	blob \| history
src/main/java/de/juplo/kafka/StatisticsDocument.java	diff1 \|	diff2 \|	blob \| history
src/test/java/de/juplo/kafka/ApplicationTests.java	\|	diff2 \|	blob \| history