From: Kai Moritz Date: Wed, 7 May 2025 17:38:03 +0000 (+0200) Subject: Eigene Version für Livecoding X-Git-Tag: spring/spring-consumer--livecoding--2025-05-lvm X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=refs%2Fheads%2Fspring%2Fspring-consumer--livecoding;p=demos%2Fkafka%2Ftraining Eigene Version für Livecoding --- diff --git a/README.sh b/README.sh index 85b8f96..731dd4f 100755 --- a/README.sh +++ b/README.sh @@ -1,6 +1,6 @@ #!/bin/bash -IMAGE=juplo/simple-consumer:1.0-SNAPSHOT +IMAGE=juplo/spring-consumer:1.1-livecoding-SNAPSHOT if [ "$1" = "cleanup" ] then diff --git a/build.gradle b/build.gradle index be0bc47..870cf9b 100644 --- a/build.gradle +++ b/build.gradle @@ -8,7 +8,7 @@ plugins { } group = 'de.juplo.kafka' -version = '1.0-SNAPSHOT' +version = '1.1-livecoding-SNAPSHOT' java { toolchain { diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml index 9553900..7b0958b 100644 --- a/docker/docker-compose.yml +++ b/docker/docker-compose.yml @@ -140,8 +140,25 @@ services: command: kafka:9092 test producer consumer: - image: juplo/simple-consumer:1.0-SNAPSHOT - command: kafka:9092 test my-group consumer + image: juplo/spring-consumer:1.1-livecoding-SNAPSHOT + environment: + juplo.bootstrap-server: kafka:9092 + juplo.client-id: consumer + juplo.consumer.topic: test + + peter: + image: juplo/spring-consumer:1.1-livecoding-SNAPSHOT + environment: + juplo.bootstrap-server: kafka:9092 + juplo.client-id: peter + juplo.consumer.topic: test + + ute: + image: juplo/spring-consumer:1.1-livecoding-SNAPSHOT + environment: + juplo.bootstrap-server: kafka:9092 + juplo.client-id: ute + juplo.consumer.topic: test volumes: zookeeper-data: diff --git a/pom.xml b/pom.xml index a100717..bb5107c 100644 --- a/pom.xml +++ b/pom.xml @@ -12,10 +12,10 @@ de.juplo.kafka - simple-consumer - Simple Consumer-Group - Super Simple Consumer-Group, that is implemented as a plain Java-program - 1.0-SNAPSHOT + spring-consumer + Spring Consumer + Super Simple Consumer-Group, that is implemented as Spring-Boot application and configured by Spring Kafka + 1.1-livecoding-SNAPSHOT 21