projects
/
demos
/
kafka
/
training
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Version des Rest-Producers, der direkt Requests für den Sumup-Adder sendet
[demos/kafka/training]
/
docker
/
docker-compose.yml
diff --git
a/docker/docker-compose.yml
b/docker/docker-compose.yml
index
0569a91
..
e2b3c43
100644
(file)
--- a/
docker/docker-compose.yml
+++ b/
docker/docker-compose.yml
@@
-80,7
+80,7
@@
services:
akhq:
image: tchiotludo/akhq:0.23.0
ports:
akhq:
image: tchiotludo/akhq:0.23.0
ports:
- - 8
000
:8080
+ - 8
888
:8080
environment:
AKHQ_CONFIGURATION: |
akhq:
environment:
AKHQ_CONFIGURATION: |
akhq:
@@
-100,7
+100,7
@@
services:
- setup
producer:
- setup
producer:
- image: juplo/rest-producer:1.0-SNAPSHOT
+ image: juplo/rest-producer
--json
:1.0-SNAPSHOT
ports:
- 8080:8080
environment:
ports:
- 8080:8080
environment:
@@
-109,28
+109,28
@@
services:
producer.client-id: producer
producer.topic: test
producer.client-id: producer
producer.topic: test
- p
roducer-0
:
- image: juplo/
rest-producer:1.0-SNAPSHOT
- ports:
- - 8000:8080
- environment:
- server.port: 8080
- producer.bootstrap-server: kafka:9092
- producer.client-id: producer-0
- producer.topic: test
- producer.partition: 0
+ p
eter
:
+ image: juplo/
toolbox
+ command: >
+ bash -c "
+ while [[ true ]];
+ do
+ echo 777 | http -v producer:8080/peter;
+ sleep 1;
+ done
+ "
-
producer-1
:
- image: juplo/
rest-producer:1.0-SNAPSHOT
- ports:
- - 8001:8080
- environment:
- server.port: 8080
- producer.bootstrap-server: kafka:9092
- producer.client-id: producer-1
- producer.topic: test
- producer.partition: 1
+
klaus
:
+ image: juplo/
toolbox
+ command: >
+ bash -c "
+ while [[ true ]];
+ do
+ echo 666 | http -v producer:8080/klaus;
+ sleep 1;
+ done
+ "
consumer:
consumer:
- image: juplo/
simple-consumer:1.0-SNAPSHOT
- command: kafka
:9092 test my-group consumer
+ image: juplo/
toolbox
+ command: kafka
cat -C -b kafka:9092 -t test -o 0 -f'p=%p|o=%o|k=%k|v=%s\n'