From 06ec8e6de68b37f088ae68eb89fa137d10851496 Mon Sep 17 00:00:00 2001 From: GabrielNicolasAvellaneda Date: Thu, 1 Oct 2015 10:48:35 -0300 Subject: [PATCH] Catch UnsupportedOptionException to show a friendly error message. Signed-off-by: GabrielNicolasAvellaneda --- core/src/main/scala/kafka/tools/ConsoleProducer.scala | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/core/src/main/scala/kafka/tools/ConsoleProducer.scala b/core/src/main/scala/kafka/tools/ConsoleProducer.scala index 6971e6e4dcc15..de50f651624c4 100644 --- a/core/src/main/scala/kafka/tools/ConsoleProducer.scala +++ b/core/src/main/scala/kafka/tools/ConsoleProducer.scala @@ -33,11 +33,11 @@ object ConsoleProducer { def main(args: Array[String]) { - val config = new ProducerConfig(args) - val reader = Class.forName(config.readerClass).newInstance().asInstanceOf[MessageReader] - reader.init(System.in, getReaderProps(config)) - try { + val config = new ProducerConfig(args) + val reader = Class.forName(config.readerClass).newInstance().asInstanceOf[MessageReader] + reader.init(System.in, getReaderProps(config)) + val producer = if(config.useNewProducer) { new NewShinyProducer(getNewProducerProps(config)) @@ -58,6 +58,9 @@ object ConsoleProducer { producer.send(message.topic, message.key, message.message) } while(message != null) } catch { + case e: joptsimple.OptionException => + System.err.println(e.getMessage) + System.exit(1) case e: Exception => e.printStackTrace System.exit(1)