X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=docker-compose.yml;h=27568ce47d8ffcda21785d6f096054165e7cb7d1;hb=ef5317621e092f8f0ab255934c9d06338f3b6889;hp=fd115c4b212d7959b78d89246b8cb64615dca242;hpb=d4a7abb3e82b434e64b55ae1d69a9a44e0bfbb07;p=demos%2Fkafka%2Ftraining diff --git a/docker-compose.yml b/docker-compose.yml index fd115c4..27568ce 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -61,7 +61,7 @@ services: - zookeeper cli: - image: confluentinc/cp-kafkacat:7.1.3 + image: confluentinc/cp-kafka:7.1.3 command: sleep infinity setup: @@ -79,9 +79,7 @@ services: image: confluentinc/cp-kafkacat:7.1.3 command: > bash -c " - echo 'hello world' | kafkacat -P -b kafka:9092 -t test -X acks=all - echo 'hello world' | kafkacat -P -b kafka:9092 -t test -X acks=all - echo 'hello world' | kafkacat -P -b kafka:9092 -t test -X acks=all + echo -e \"hello world\nhow are you\nI hope, you're fine\" | kafkacat -P -b kafka:9092 -t test -X acks=all " consumer: