kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Remove unnecessary semi-colons
Date Tue, 10 Jan 2017 11:41:13 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 044b56b8b -> 1fea1c390


MINOR: Remove unnecessary semi-colons

Author: Mickael Maison <mickael.maison@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #2326 from mimaison/minor-fixes


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1fea1c39
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1fea1c39
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1fea1c39

Branch: refs/heads/trunk
Commit: 1fea1c390846673fd39452100e949be61c21b9ce
Parents: 044b56b
Author: Mickael Maison <mickael.maison@gmail.com>
Authored: Tue Jan 10 11:38:26 2017 +0000
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Tue Jan 10 11:41:04 2017 +0000

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/ConfigHandler.scala   | 2 +-
 core/src/main/scala/kafka/tools/ConsoleConsumer.scala  | 2 +-
 core/src/test/scala/unit/kafka/log/LogConfigTest.scala | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/1fea1c39/core/src/main/scala/kafka/server/ConfigHandler.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ConfigHandler.scala b/core/src/main/scala/kafka/server/ConfigHandler.scala
index dc21f83..7f204d5 100644
--- a/core/src/main/scala/kafka/server/ConfigHandler.scala
+++ b/core/src/main/scala/kafka/server/ConfigHandler.scala
@@ -140,7 +140,7 @@ class UserConfigHandler(private val quotaManagers: QuotaManagers) extends
QuotaC
     // Entity path is <user> or <user>/clients/<client>
     val entities = quotaEntityPath.split("/")
     if (entities.length != 1 && entities.length != 3)
-      throw new IllegalArgumentException("Invalid quota entity path: " + quotaEntityPath);
+      throw new IllegalArgumentException("Invalid quota entity path: " + quotaEntityPath)
     val sanitizedUser = entities(0)
     val clientId = if (entities.length == 3) Some(entities(2)) else None
     updateQuotaConfig(Some(sanitizedUser), clientId, config)

http://git-wip-us.apache.org/repos/asf/kafka/blob/1fea1c39/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
index eea66f8..4c133c3 100755
--- a/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
+++ b/core/src/main/scala/kafka/tools/ConsoleConsumer.scala
@@ -51,7 +51,7 @@ object ConsoleConsumer extends Logging {
     } catch {
       case e: Throwable =>
         error("Unknown error when running consumer: ", e)
-        System.exit(1);
+        System.exit(1)
     }
   }
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/1fea1c39/core/src/test/scala/unit/kafka/log/LogConfigTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/log/LogConfigTest.scala b/core/src/test/scala/unit/kafka/log/LogConfigTest.scala
index ccb1e60..862083d 100644
--- a/core/src/test/scala/unit/kafka/log/LogConfigTest.scala
+++ b/core/src/test/scala/unit/kafka/log/LogConfigTest.scala
@@ -73,7 +73,7 @@ class LogConfigTest {
       case LogConfig.UncleanLeaderElectionEnableProp => assertPropertyInvalid(name, "not
a boolean")
       case LogConfig.RetentionBytesProp => assertPropertyInvalid(name, "not_a_number")
       case LogConfig.RetentionMsProp => assertPropertyInvalid(name, "not_a_number" )
-      case LogConfig.CleanupPolicyProp => assertPropertyInvalid(name, "true", "foobar");
+      case LogConfig.CleanupPolicyProp => assertPropertyInvalid(name, "true", "foobar")
       case LogConfig.MinCleanableDirtyRatioProp => assertPropertyInvalid(name, "not_a_number",
"-0.1", "1.2")
       case LogConfig.MinInSyncReplicasProp => assertPropertyInvalid(name, "not_a_number",
"0", "-1")
       case LogConfig.MessageFormatVersionProp => assertPropertyInvalid(name, "")


Mime
View raw message