Skip to content
This repository was archived by the owner on Mar 23, 2022. It is now read-only.

Commit

Permalink
Don't shadow an outer variable
Browse files Browse the repository at this point in the history
  • Loading branch information
miguno committed Dec 3, 2014
1 parent 9373adf commit 29671be
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
}
Expand Down

0 comments on commit 29671be

Please sign in to comment.