Setup und Beispiel in README.sh überarbeitet supersimple-consumer supersimple-consumer--2023-02-signal
authorKai Moritz <kai@juplo.de>
Sun, 29 Jan 2023 18:50:47 +0000 (19:50 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 30 Jan 2023 17:50:54 +0000 (18:50 +0100)
- Der Consumer ist jetzt mit `auto.offset.reset=earliest` konfiguriert.
- Ansonsten sind die Nachrichten des `supersimple-producer`, nicht zu
  sehen gewesen, da dieser nicht endlos schreibt und mit dem Schreiben
  stets fertig war, bevor `supersimple-consumer` mit dem Lesen begonnen
  hat.
- Beispiel in `README.sh` vereinfacht.

README.sh
docker-compose.yml

index 97244dc..de29879 100755 (executable)
--- a/README.sh
+++ b/README.sh
@@ -24,15 +24,6 @@ else
 fi
 
 docker-compose up setup
-docker-compose up -d producer
-docker-compose ps
-
-docker-compose up -d consumer
-sleep 5
-docker-compose stop consumer
-
-docker-compose start consumer
+docker-compose up -d producer consumer
 sleep 5
-
-docker-compose stop producer consumer
 docker-compose logs consumer
index 353b52b..f99a639 100644 (file)
@@ -120,4 +120,5 @@ services:
       server.port: 8080
       spring.kafka.bootstrap-servers: kafka:9092
       spring.kafka.client-id: consumer
+      spring.kafka.consumer.auto-offset-reset: earliest
       logging.level.org.apache.kafka.clients.consumer: INFO