Kai Moritz [Sat, 12 Nov 2022 14:01:00 +0000 (15:01 +0100)]
Konsumption der Nachricht in eine separate Methode verlagert
* Dies ist eine Vorbereitung für die Umstellung auf `@KafkaListener`
* Durch die Umstellung wird der Code vor/nach der Umstellung besser
vergleichbar.
* Denn mit `@KafkaListener` wird direkt eine Methode annotiert, die dann
von Spring die deserialisierte Nachricht injiziert bekommt.
* Einziger gangbarer Weg, um IntelliJ beizubiegen, Leerzeichen für die
Einrückung zu verwenden!
* ...aber auch für einige andere Dinge ganz praktisch...
Kai Moritz [Mon, 24 Oct 2022 15:33:02 +0000 (17:33 +0200)]
Setup auf KRAFT umgestellt
* Der Zookeeper wird dann nicht mehr benötigt.
* Broker-Images auf `bitnami/kafka:3.3.1` umgestellt, da die Confluent-
Images den KRAFT-Modus noch nicht unterstützen.
Kai Moritz [Tue, 2 Aug 2022 20:01:35 +0000 (22:01 +0200)]
Compose-Setup an das aus den Producer-Übungen angepasst
* Es wird jetzt der Rest-Producer verwendet.
* Um die Nachrichten zu erzeugen, werden die Rest-Clients verwendet.
* Ziel: Dies ist näher an dem Setup aus den Wordcount-Übungen.
* Versucht das Timing in dem README-Skript unabhängiger von Timing-Fragen
zu machen - scheitert aber daran, dass das Skript nicht gezielt darauf
warten kann, dass das neu angelegte Topic zur Verfügung steht.
Kai Moritz [Tue, 2 Aug 2022 19:00:36 +0000 (21:00 +0200)]
Für eine Übersichtliche Übergabe sollte CooperativeStickyAssignor aktiv sein
* Per Default ist immer noch der RangeAssignor vorgegeben, so dass die
Partitionen bei jedem Rebalance komplett neu zugeordnet werden.
* Um bei der Betrachtung der Effekte von Sauberem Stop vs. Kill vs. Freeze
den Überblick behalten zu können, wurde der CooperativeStickyAssignor
aktiviert.
* Unterschiede zu dem Producer aus `first-contact`:
** Der Producer erzeugt endlos alle ca. 500ms eine Nachricht.
** Der Producer beendet sich ordentlich, wenn STRG-C gedrückt wird.
** Der Producer wird auch als Docker-Image gebaut
* Das Compose-Setup an das Setup aus den vorhergehenden Übungen
angegelichen.
Kai Moritz [Fri, 22 Jul 2022 18:04:07 +0000 (20:04 +0200)]
Upgrade von Spring Boot und den Confluent-Kafka-Images
* Upgrade der Kafk-Images von Confluent 7.0.2 auf 7.1.3
** Unterstützt Kafka 3.1.x (siehe https://docs.confluent.io/platform/current/installation/versions-interoperability.html[Versions-Matrix])
* Upgrade für Spring Boot von 2.6.5 auf 2.7.2
** Enthält Kafka: 3.1.1
** Enthält Spring Kafka: 2.8.8