kafka: fix audit error

Closes #6356. Signed-off-by: Alex Dunn <dunn.alex@gmail.com>
Homebrew · Nov 7, 2016 · f41d91b · f41d91b
1 parent 3a2079d
commit f41d91b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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