kafka: fix audit error

Closes #6356.

Signed-off-by: Alex Dunn <dunn.alex@gmail.com>
This commit is contained in:
Ondrej Galbavy 2016-10-28 23:05:30 +02:00 committed by Alex Dunn
parent 3a2079d4a5
commit f41d91bc8a
No known key found for this signature in database
GPG key ID: 8C81F8F098CA78D8

View file

@ -102,7 +102,7 @@ class Kafka < Formula
sleep 30
system "#{bin}/kafka-topics --zookeeper localhost:2181 --create --if-not-exists --replication-factor 1 --partitions 1 --topic test > #{testpath}/kafka/demo.out 2>/dev/null"
system "echo \"test message\" | #{bin}/kafka-console-producer --broker-list localhost:9092 --topic test 2>/dev/null"
pipe_output("#{bin}/kafka-console-producer --broker-list localhost:9092 --topic test 2>/dev/null", "test message")
system "#{bin}/kafka-console-consumer --zookeeper localhost:2181 --topic test --from-beginning --max-messages 1 >> #{testpath}/kafka/demo.out 2>/dev/null"
system "#{bin}/kafka-topics --zookeeper localhost:2181 --delete --topic test >> #{testpath}/kafka/demo.out 2>/dev/null"
ensure