From 29671be796e00413e1cd762c7f2818f090fb0270 Mon Sep 17 00:00:00 2001 From: "Michael G. Noll" Date: Wed, 3 Dec 2014 13:55:41 +0100 Subject: [PATCH] Don't shadow an outer variable --- .../scala/com/miguno/kafkastorm/kafka/KafkaProducerApp.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/com/miguno/kafkastorm/kafka/KafkaProducerApp.scala b/src/main/scala/com/miguno/kafkastorm/kafka/KafkaProducerApp.scala index 35e47d6..51f232e 100644 --- a/src/main/scala/com/miguno/kafkastorm/kafka/KafkaProducerApp.scala +++ b/src/main/scala/com/miguno/kafkastorm/kafka/KafkaProducerApp.scala @@ -46,7 +46,7 @@ case class KafkaProducerApp(brokerList: String, val t = topic.getOrElse(defaultTopic.getOrElse(throw new IllegalArgumentException("Must provide topic or default topic"))) require(!t.isEmpty, "Topic must not be empty") key match { - case Some(key) => new KeyedMessage(t, key, value) + case Some(k) => new KeyedMessage(t, k, value) case _ => new KeyedMessage(t, value) } }