From f41d91bc8a2e4e90a0166c8f5ae24b0f3c642e0b Mon Sep 17 00:00:00 2001 From: Ondrej Galbavy Date: Fri, 28 Oct 2016 23:05:30 +0200 Subject: [PATCH] kafka: fix audit error Closes #6356. Signed-off-by: Alex Dunn --- Formula/kafka.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Formula/kafka.rb b/Formula/kafka.rb index 9979776a0a088..c59cd023068c4 100644 --- a/Formula/kafka.rb +++ b/Formula/kafka.rb @@ -102,7 +102,7 @@ def plist; <<-EOS.undent 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