fi
docker compose -f docker/docker-compose.yml up -d --remove-orphans kafka-1 kafka-2 kafka-3
-docker compose -f docker/docker-compose.yml rm -svf consumer
+docker compose -f docker/docker-compose.yml rm -svf consumer-1
if [[
$(docker image ls -q $IMAGE) == "" ||
docker compose -f docker/docker-compose.yml up -d producer
-docker compose -f docker/docker-compose.yml up -d consumer
+docker compose -f docker/docker-compose.yml up -d consumer-1
-sleep 5
-docker compose -f docker/docker-compose.yml stop consumer
+sleep 10
+docker compose -f docker/docker-compose.yml exec cli http consumer-1:8881/
-docker compose -f docker/docker-compose.yml start consumer
-sleep 5
-
-docker compose -f docker/docker-compose.yml stop producer consumer
-docker compose -f docker/docker-compose.yml logs consumer
+docker compose -f docker/docker-compose.yml stop producer consumer-1
juplo.client-id: producer
juplo.producer.topic: test
juplo.producer.linger-ms: 666
- juplo.producer.throttle-ms: 100
+ juplo.producer.throttle-ms: 10
consumer:
image: juplo/spring-consumer:1.1-log-compaction-SNAPSHOT
juplo.bootstrap-server: kafka:9092
juplo.client-id: consumer
juplo.consumer.topic: test
+ juplo.producer.linger-ms: 1000
+ logging.level.de.juplo: TRACE
peter:
- image: juplo/spring-consumer:1.1-SNAPSHOT
+ image: juplo/spring-consumer:1.1-log-compaction-SNAPSHOT
environment:
juplo.bootstrap-server: kafka:9092
juplo.client-id: peter
juplo.consumer.topic: test
+ juplo.producer.linger-ms: 1000
+ logging.level.de.juplo: TRACE
ute:
- image: juplo/spring-consumer:1.1-SNAPSHOT
+ image: juplo/spring-consumer:1.1-log-compaction-SNAPSHOT
environment:
juplo.bootstrap-server: kafka:9092
juplo.client-id: ute
juplo.consumer.topic: test
+ juplo.producer.linger-ms: 1000
+ logging.level.de.juplo: TRACE
volumes:
zookeeper-data: