Repository: kafka Updated Branches: refs/heads/trunk e108a8b4e -> b948f4327
KAFKA-2955; Add a simple ">" prompt to console producer Author: Manikumar reddy O <manikumar.re...@gmail.com> Reviewers: Ismael Juma, Guozhang Wang, Gwen Shapira Closes #1233 from omkreddy/KAFKA-2955 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b948f432 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b948f432 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b948f432 Branch: refs/heads/trunk Commit: b948f43278e7641977c07df0069158a61fd3b443 Parents: e108a8b Author: Manikumar reddy O <manikumar.re...@gmail.com> Authored: Tue Jan 31 09:30:29 2017 -0800 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Tue Jan 31 09:30:29 2017 -0800 ---------------------------------------------------------------------- core/src/main/scala/kafka/tools/ConsoleProducer.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/b948f432/core/src/main/scala/kafka/tools/ConsoleProducer.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index c6dcfce..93454d6 100644 --- a/core/src/main/scala/kafka/tools/ConsoleProducer.scala +++ b/core/src/main/scala/kafka/tools/ConsoleProducer.scala @@ -306,6 +306,7 @@ object ConsoleProducer { override def readMessage() = { lineNumber += 1 + print(">") (reader.readLine(), parseKey) match { case (null, _) => null case (line, true) =>
