echo "Kafka container is up and running. Starting producer and consumer..."
space
+#Using the autostart flag in the application.yaml
echo "Start 1 Producer on mytopic"
-curl -X GET http://localhost:8080/startProducer/mytopic
+#curl -X GET http://localhost:8080/startProducer/mytopic
space
echo "Start 1 Consumer on mytopic"
-curl -X GET http://localhost:8081/startConsumer/mytopic
+#curl -X GET http://localhost:8081/startConsumer/mytopic
space
sleep 10
for container in "${containers[@]}"; do
if docker logs "$container" | grep -q ERROR; then
echo "Errors found in logs of $container"
+ docker logs "$container" | grep ERROR
echo "FAIL"
exit 1
else