]> juplo.de Git - demos/kafka/training/log
demos/kafka/training
10 months agoDer Payload einer Nachricht wird über alle Nachrichten hochgezählt
Kai Moritz [Sun, 15 Dec 2024 11:03:17 +0000 (12:03 +0100)]
Der Payload einer Nachricht wird über alle Nachrichten hochgezählt

10 months agorefactor:TEST
Kai Moritz [Sun, 15 Dec 2024 10:58:16 +0000 (11:58 +0100)]
refactor:TEST

10 months agoTEST
Kai Moritz [Sat, 23 Nov 2024 08:34:22 +0000 (09:34 +0100)]
TEST

10 months agoCallback für das Beenden der SpringBoot-App in eine Bean verwandelt
Kai Moritz [Sat, 14 Dec 2024 11:55:35 +0000 (12:55 +0100)]
Callback für das Beenden der SpringBoot-App in eine Bean verwandelt

11 months ago`ConsumerHealthIndicator` refaktorisiert (Methoden aufgeräumt)
Kai Moritz [Sat, 23 Nov 2024 09:26:30 +0000 (10:26 +0100)]
`ConsumerHealthIndicator` refaktorisiert (Methoden aufgeräumt)

11 months ago`ConsumerHealthIndicator` refaktorisiert (Klareres Benennungs-Schema)
Kai Moritz [Sat, 23 Nov 2024 09:25:07 +0000 (10:25 +0100)]
`ConsumerHealthIndicator` refaktorisiert (Klareres Benennungs-Schema)

11 months ago`ConsumerHealthIndicator` refaktorisiert (Aufgaben klarer getrennt)
Kai Moritz [Sat, 23 Nov 2024 09:18:48 +0000 (10:18 +0100)]
`ConsumerHealthIndicator` refaktorisiert (Aufgaben klarer getrennt)

11 months ago`ConsumerHealthIndicator` refaktorisiert (DRY)
Kai Moritz [Mon, 18 Nov 2024 18:24:49 +0000 (19:24 +0100)]
`ConsumerHealthIndicator` refaktorisiert (DRY)

11 months ago`HealthIndicator` mit Details zu Rebalances des Consumers implementiert
Kai Moritz [Mon, 18 Nov 2024 06:38:42 +0000 (07:38 +0100)]
`HealthIndicator` mit Details zu Rebalances des Consumers implementiert

11 months agoHandling der Nachricht in das Interface `RecordHandler` verlegt
Kai Moritz [Sun, 17 Nov 2024 12:06:26 +0000 (13:06 +0100)]
Handling der Nachricht in das Interface `RecordHandler` verlegt

11 months agoVersion des ``spring-consumer``, der Deserialisierungs-Fehler überspringt consumer/spring-consumer--deserialization-error--2024-11-signal
Kai Moritz [Sun, 10 Nov 2024 16:57:23 +0000 (17:57 +0100)]
Version des ``spring-consumer``, der Deserialisierungs-Fehler überspringt

11 months agoVersion des ``spring-consumer``, die ``long``-Werte erwartet consumer/spring-consumer--long--2024-11-signal
Kai Moritz [Sun, 10 Nov 2024 16:30:57 +0000 (17:30 +0100)]
Version des ``spring-consumer``, die ``long``-Werte erwartet

11 months agoDas Docker-Setup verwendet den `spring-producer` consumer/spring-consumer--2024-11-signal consumer/spring-consumer--2024-12-signal
Kai Moritz [Sun, 10 Nov 2024 12:50:32 +0000 (13:50 +0100)]
Das Docker-Setup verwendet den `spring-producer`

* Die Konfiguration wurde außerdem so überarbeitet, dass der Producer
  mehr Nachrichten verschickt (ca. 10 Nachrichten pro Sekunde) und diese
  in Batches à ca. 6 Nachrichten verpackt.

11 months agoUngefangene Exceptions im `ExampleConsumer` lösen das Beenden der App aus
Kai Moritz [Sat, 2 Nov 2024 22:19:40 +0000 (23:19 +0100)]
Ungefangene Exceptions im `ExampleConsumer` lösen das Beenden der App aus

11 months agoFix: `close()` muss noch vom `ExampleConsumer` aufgerufen werden
Kai Moritz [Sat, 2 Nov 2024 21:23:16 +0000 (22:23 +0100)]
Fix: `close()` muss noch vom `ExampleConsumer` aufgerufen werden

* Der Aufruf von `close()` löst die Abmeldung der Instanz bei dem
  GroupCoordinator aus.
* Dieser Vorgang sollte noch unter der Kontrolle des Anwendungscodes
  erfolgen!
* Wenn die Methode erst von Spring aufgerufen wird, werden dann ggf. noch
  Seiteneffekte ausgelöst, die dann noch im Kontext der Instanz laufen,
  obwohl diese eigentlich schon beendet wurde!

11 months agoConsumerspezifische Properties werden in eigener nested Class verwaltet
Kai Moritz [Mon, 28 Oct 2024 07:46:58 +0000 (08:46 +0100)]
Consumerspezifische Properties werden in eigener nested Class verwaltet

* Dadurch wird der Code übersichtlicher, wenn spätere Implementierungen
  _sowohl_ als Consumer, _als auch_ als Producer agieren!

11 months ago`ExampleConsumer` in eine Spring-Boot App umgebaut (ohne Spring Kafka)
Kai Moritz [Sun, 27 Oct 2024 21:08:53 +0000 (22:08 +0100)]
`ExampleConsumer` in eine Spring-Boot App umgebaut (ohne Spring Kafka)

11 months agoHandling der Records wie in abgeleiteten Versionen in eigener Methode grundlagen/simple-consumer--2024-11-signal grundlagen/simple-consumer--2024-12-signal
Kai Moritz [Sun, 29 Sep 2024 12:30:42 +0000 (14:30 +0200)]
Handling der Records wie in abgeleiteten Versionen in eigener Methode

11 months ago`metadata.maxage.ms` auf 5 Sekunden heruntergesetzt
Kai Moritz [Sat, 28 Sep 2024 10:00:20 +0000 (12:00 +0200)]
`metadata.maxage.ms` auf 5 Sekunden heruntergesetzt

11 months ago`simple-producer` in `simple-consumer` verwandelt -- ALIGN
Kai Moritz [Thu, 26 Sep 2024 13:21:01 +0000 (15:21 +0200)]
`simple-producer` in `simple-consumer` verwandelt -- ALIGN

11 months ago`simple-producer` in `simple-consumer` verwandelt -- COPY
Kai Moritz [Mon, 28 Oct 2024 13:14:51 +0000 (14:14 +0100)]
`simple-producer` in `simple-consumer` verwandelt -- COPY

11 months ago`metadata.maxage.ms` auf 5 Sekunden heruntergesetzt
Kai Moritz [Sat, 28 Sep 2024 09:58:11 +0000 (11:58 +0200)]
`metadata.maxage.ms` auf 5 Sekunden heruntergesetzt

11 months agoBei einem unerwarteten Fehler wird auch der Stacktrace mit ausgegeben grundlagen/simple-producer--2024-11-signal grundlagen/simple-producer--2024-12-signal
Kai Moritz [Fri, 1 Nov 2024 14:53:17 +0000 (15:53 +0100)]
Bei einem unerwarteten Fehler wird auch der Stacktrace mit ausgegeben

11 months agoDer Nachrichten-Wert wird in allen Log-Meldungen mit ausgegeben
Kai Moritz [Thu, 31 Oct 2024 23:52:44 +0000 (00:52 +0100)]
Der Nachrichten-Wert wird in allen Log-Meldungen mit ausgegeben

11 months agoLogging-Pattern überarbeitet
Kai Moritz [Mon, 28 Oct 2024 11:03:50 +0000 (12:03 +0100)]
Logging-Pattern überarbeitet

11 months agoUnnötige Kommandos aus der `README.sh` entfernt
Kai Moritz [Sun, 29 Sep 2024 07:44:09 +0000 (09:44 +0200)]
Unnötige Kommandos aus der `README.sh` entfernt

11 months ago`docker` in `simple-producer` verwandelt`
Kai Moritz [Sat, 28 Sep 2024 05:49:04 +0000 (07:49 +0200)]
`docker` in `simple-producer` verwandelt`

12 months ago`log.retention.check.interval.ms` auf 10 Sekunden gesetzt
Kai Moritz [Sat, 26 Oct 2024 17:42:02 +0000 (19:42 +0200)]
`log.retention.check.interval.ms` auf 10 Sekunden gesetzt

12 months ago``version``-Eintrag in `docker-compose.yml` entfernt
Kai Moritz [Sat, 28 Sep 2024 09:08:51 +0000 (11:08 +0200)]
``version``-Eintrag in `docker-compose.yml` entfernt

12 months ago"Final Newline" in `.editorconfig` gefordert (scheint vim zu entsprechen)
Kai Moritz [Sat, 28 Sep 2024 07:42:36 +0000 (09:42 +0200)]
"Final Newline" in `.editorconfig` gefordert (scheint vim zu entsprechen)

12 months ago`.gitignore` und `.editorconfig` hinzugefügt
Kai Moritz [Sat, 28 Sep 2024 06:35:51 +0000 (08:35 +0200)]
`.gitignore` und `.editorconfig` hinzugefügt

12 months agoSchreibweise des CLI-Kommandos für Docker-Compose korrigiert
Kai Moritz [Sat, 28 Sep 2024 05:43:48 +0000 (07:43 +0200)]
Schreibweise des CLI-Kommandos für Docker-Compose korrigiert

13 months agoUpgrade der verwendeten Kafka-Images auf 7.7.1
Kai Moritz [Wed, 25 Sep 2024 12:26:14 +0000 (14:26 +0200)]
Upgrade der verwendeten Kafka-Images auf 7.7.1

23 months agoZooNavigator in den Demo-Stack aufgenommen
Kai Moritz [Sun, 8 Oct 2023 13:23:57 +0000 (15:23 +0200)]
ZooNavigator in den Demo-Stack aufgenommen

2 years ago`README.sh` bricht ab, wenn `setup` nicht erfolgreich ist!
Kai Moritz [Sat, 14 Oct 2023 17:25:10 +0000 (19:25 +0200)]
`README.sh` bricht ab, wenn `setup` nicht erfolgreich ist!

2 years agoStart von Service `setup` startet auch `cli`
Kai Moritz [Fri, 13 Oct 2023 11:39:45 +0000 (13:39 +0200)]
Start von Service `setup` startet auch `cli`

2 years agoDer Service `setup` wartet bereits auf den Cluster
Kai Moritz [Sat, 14 Oct 2023 16:44:10 +0000 (18:44 +0200)]
Der Service `setup` wartet bereits auf den Cluster

2 years agoGrace-Period für Broker und cli/setup gesetzt
Kai Moritz [Fri, 13 Oct 2023 08:17:23 +0000 (10:17 +0200)]
Grace-Period für Broker und cli/setup gesetzt

2 years agoSchönere YAML-Syntax für `setup`-Service
Kai Moritz [Fri, 6 Oct 2023 17:13:41 +0000 (19:13 +0200)]
Schönere YAML-Syntax für `setup`-Service

2 years agoServices `schema-registry` und `connect` hinzugefügt
Kai Moritz [Fri, 6 Oct 2023 14:28:46 +0000 (16:28 +0200)]
Services `schema-registry` und `connect` hinzugefügt

2 years agoHilfs-Services `setup` überarbeitet
Kai Moritz [Fri, 6 Oct 2023 13:12:37 +0000 (15:12 +0200)]
Hilfs-Services `setup` überarbeitet

2 years agoVolumes für die Log-/Config-Daten und Zookeeper hinzugefügt
Kai Moritz [Mon, 16 Oct 2023 19:13:52 +0000 (21:13 +0200)]
Volumes für die Log-/Config-Daten und Zookeeper hinzugefügt

2 years agoSetup zurück auf Confluent (Version 7.5.1) mit Zookeeper umestellt
Kai Moritz [Mon, 16 Oct 2023 19:05:08 +0000 (21:05 +0200)]
Setup zurück auf Confluent (Version 7.5.1) mit Zookeeper umestellt

2 years agoAKHQ auf einen eindeutigeren Port verlegt grundlagen/docker---2023-06-signal
Kai Moritz [Mon, 12 Jun 2023 19:21:06 +0000 (21:21 +0200)]
AKHQ auf einen eindeutigeren Port verlegt

2 years agoAutomatisches entfernen von Orphans beim Start
Kai Moritz [Sun, 11 Jun 2023 21:14:51 +0000 (23:14 +0200)]
Automatisches entfernen von Orphans beim Start

2 years agoDocker-Setup in das Unterverzeichnis `docker` verschoben
Kai Moritz [Sun, 11 Jun 2023 12:46:07 +0000 (14:46 +0200)]
Docker-Setup in das Unterverzeichnis `docker` verschoben

2 years agoDocker-Setup auf `bitnami/kafka:3.4` aktualisiert und vereinfacht
Kai Moritz [Sun, 11 Jun 2023 11:55:20 +0000 (13:55 +0200)]
Docker-Setup auf `bitnami/kafka:3.4` aktualisiert und vereinfacht

* Die Konfiguration musste an (undokumentierte?!) Änderungen in der
  version 3.4 von `bitnami/kafka` angepasst werden.
* Die drei Broker spielen jetzt gleichzeitig Controller. D.h., der
  Service `kafka-0`, der explizit Controller gespielt hat, fällt weg.

2 years agoBedienbarkeit des Setups verbessert
Kai Moritz [Thu, 8 Jun 2023 08:35:41 +0000 (10:35 +0200)]
Bedienbarkeit des Setups verbessert

* Setup starten mit `docker-compose up -t0 -d cli`
** Dabei wird _nicht_ automatisch das Topic `test` neu angelegt
** D.h., die Daten gehen nicht unbeabsichtigt verloren, wenn man mit
   `up -d` prüft, ob noc alles läuft!
* Das Topic `test` kan mit `docker-compose restart -t0 setup` explizit
  gelöscht und neu angelegt (aka geleert) werden.

2 years ago`docker-compose up setup` startet auch die cli docker--2023-02-signal
Kai Moritz [Thu, 8 Dec 2022 17:38:43 +0000 (18:38 +0100)]
`docker-compose up setup` startet auch die cli

2 years agoAKHQ zu dem Basis-Setup hinzugefügt
Kai Moritz [Thu, 8 Dec 2022 17:37:08 +0000 (18:37 +0100)]
AKHQ zu dem Basis-Setup hinzugefügt

2 years agoCompose-Setup auf bitnami mit KRAFT umgestellt docker--lvm-2-tage--easy-path
Kai Moritz [Mon, 21 Nov 2022 21:58:22 +0000 (22:58 +0100)]
Compose-Setup auf bitnami mit KRAFT umgestellt

* Setup aus Unterschied zu `spring-consumer--json--adder` übernommen.
* Auch das `README.sh` entsprechend angepasst.

3 years agoFür ordering-Übung werden zwei Partitionen benötigt! docker---lvm-2-tage
Kai Moritz [Tue, 26 Jul 2022 17:58:49 +0000 (19:58 +0200)]
Für ordering-Übung werden zwei Partitionen benötigt!

3 years agoSetup mit 3 Broker und Topic-Erzeugung mit Setup für acks-Übung
Kai Moritz [Tue, 26 Jul 2022 17:52:28 +0000 (19:52 +0200)]
Setup mit 3 Broker und Topic-Erzeugung mit Setup für acks-Übung

3 years agoMerge der Upgrades für Confluent/Spring-Boot (Branch 'first-contact')
Kai Moritz [Fri, 22 Jul 2022 18:50:15 +0000 (20:50 +0200)]
Merge der Upgrades für Confluent/Spring-Boot (Branch 'first-contact')

3 years agoUpgrade von Spring Boot und den Confluent-Kafka-Images
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

3 years agoSetup aus der Intro-Übung übernommen
Kai Moritz [Sun, 3 Apr 2022 07:26:56 +0000 (09:26 +0200)]
Setup aus der Intro-Übung übernommen

3 years agoSetup "entkernt": Implementierungen entfernt
Kai Moritz [Sun, 3 Apr 2022 07:23:57 +0000 (09:23 +0200)]
Setup "entkernt": Implementierungen entfernt

3 years agoUpgrade der Images von Confluent 6.2.0 auf 7.0.2
Kai Moritz [Sun, 3 Apr 2022 06:15:30 +0000 (08:15 +0200)]
Upgrade der Images von Confluent 6.2.0 auf 7.0.2

3 years agoREADME.sh verwendet den cli-Service für Kommandos
Kai Moritz [Fri, 1 Apr 2022 09:56:34 +0000 (11:56 +0200)]
README.sh verwendet den cli-Service für Kommandos

3 years agoFälschlich hartkodiertes Topic gegen Variable getauscht
Kai Moritz [Fri, 25 Mar 2022 14:27:50 +0000 (15:27 +0100)]
Fälschlich hartkodiertes Topic gegen Variable getauscht

3 years agoCode reorganisiert, um Änderungen vergleichbarer zu machen
Kai Moritz [Fri, 25 Mar 2022 10:19:03 +0000 (11:19 +0100)]
Code reorganisiert, um Änderungen vergleichbarer zu machen

3 years agoUpgrade für Spring Boot 2.6.0 -> 2.6.5
Kai Moritz [Fri, 25 Mar 2022 08:25:54 +0000 (09:25 +0100)]
Upgrade für Spring Boot 2.6.0 -> 2.6.5

* Kafka: 3.0.1
* Spring Kafka: 2.8.4

3 years agoFirst Contact: Simple Producer & Consumer
Kai Moritz [Tue, 14 Dec 2021 17:55:02 +0000 (18:55 +0100)]
First Contact: Simple Producer & Consumer