#!/bin/bash
-IMAGE=juplo/simple-consumer:1.0-SNAPSHOT
+IMAGE=juplo/spring-consumer:1.1-livecoding-SNAPSHOT
if [ "$1" = "cleanup" ]
then
}
group = 'de.juplo.kafka'
-version = '1.0-SNAPSHOT'
+version = '1.1-livecoding-SNAPSHOT'
java {
toolchain {
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:
</parent>
<groupId>de.juplo.kafka</groupId>
- <artifactId>simple-consumer</artifactId>
- <name>Simple Consumer-Group</name>
- <description>Super Simple Consumer-Group, that is implemented as a plain Java-program</description>
- <version>1.0-SNAPSHOT</version>
+ <artifactId>spring-consumer</artifactId>
+ <name>Spring Consumer</name>
+ <description>Super Simple Consumer-Group, that is implemented as Spring-Boot application and configured by Spring Kafka</description>
+ <version>1.1-livecoding-SNAPSHOT</version>
<properties>
<java.version>21</java.version>