You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jj...@apache.org on 2015/03/03 20:46:28 UTC
[2/3] kafka git commit: KAFKA-1499;
trivial follow-up (remove unnecessary parentheses)
KAFKA-1499; trivial follow-up (remove unnecessary parentheses)
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c5d654ac
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c5d654ac
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c5d654ac
Branch: refs/heads/trunk
Commit: c5d654acb2097eabb1784dcc88145e111a3d037b
Parents: 616987d
Author: Joel Koshy <jj...@gmail.com>
Authored: Tue Mar 3 11:18:07 2015 -0800
Committer: Joel Koshy <jj...@gmail.com>
Committed: Tue Mar 3 11:18:07 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/message/CompressionCodec.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/c5d654ac/core/src/main/scala/kafka/message/CompressionCodec.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/message/CompressionCodec.scala b/core/src/main/scala/kafka/message/CompressionCodec.scala
index c4aa8ce..4d7ce17 100644
--- a/core/src/main/scala/kafka/message/CompressionCodec.scala
+++ b/core/src/main/scala/kafka/message/CompressionCodec.scala
@@ -43,7 +43,7 @@ object BrokerCompressionCodec {
val brokerCompressionCodecs = List(UncompressedCodec, SnappyCompressionCodec, LZ4CompressionCodec, GZIPCompressionCodec, ProducerCompressionCodec)
val brokerCompressionOptions = brokerCompressionCodecs.map(codec => codec.name)
- def isValid(compressionType: String): Boolean = brokerCompressionOptions.contains((compressionType.toLowerCase()))
+ def isValid(compressionType: String): Boolean = brokerCompressionOptions.contains(compressionType.toLowerCase())
def getCompressionCodec(compressionType: String): CompressionCodec = {
compressionType.toLowerCase match {
@@ -94,4 +94,4 @@ case object UncompressedCodec extends BrokerCompressionCodec {
case object ProducerCompressionCodec extends BrokerCompressionCodec {
val name = "producer"
-}
\ No newline at end of file
+}