kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject [2/3] kafka git commit: KAFKA-1499; trivial follow-up (remove unnecessary parentheses)
Date Tue, 03 Mar 2015 19:46:28 GMT
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 <jjkoshy@gmail.com>
Authored: Tue Mar 3 11:18:07 2015 -0800
Committer: Joel Koshy <jjkoshy@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
+}


Mime
View raw message