From 99654a4a3895f410415a29e2229a011ea307cff8 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 29 Jan 2023 19:50:47 +0100 Subject: [PATCH] =?utf8?q?Setup=20und=20Beispiel=20in=20README.sh=20=C3=BC?= =?utf8?q?berarbeitet?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit - 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 | 11 +---------- docker-compose.yml | 1 + 2 files changed, 2 insertions(+), 10 deletions(-) diff --git a/README.sh b/README.sh index 97244dc..de29879 100755 --- 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 diff --git a/docker-compose.yml b/docker-compose.yml index 353b52b..f99a639 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -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 -- 2.20.1