kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: KAFKA-2061; Offer a --version flag to print the kafka version [KIP-278] (#639)
Date Fri, 25 May 2018 07:48:31 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 440445e  KAFKA-2061; Offer a --version flag to print the kafka version [KIP-278]
(#639)
440445e is described below

commit 440445e7c58508413006d37a475d642283ef984b
Author: Sasaki Toru <sasakitoa@users.noreply.github.com>
AuthorDate: Fri May 25 16:47:54 2018 +0900

    KAFKA-2061; Offer a --version flag to print the kafka version [KIP-278] (#639)
    
    Reviewers: Andy Lindeman, Jeremy Donahue, Jason Gustafson <jason@confluent.io>
---
 bin/kafka-run-class.sh                            |  6 +++++
 core/src/main/scala/kafka/utils/VersionInfo.scala | 30 +++++++++++++++++++++++
 2 files changed, 36 insertions(+)

diff --git a/bin/kafka-run-class.sh b/bin/kafka-run-class.sh
index 7a0a92a..0ea8b83 100755
--- a/bin/kafka-run-class.sh
+++ b/bin/kafka-run-class.sh
@@ -238,6 +238,12 @@ if [ -z "$KAFKA_JVM_PERFORMANCE_OPTS" ]; then
   KAFKA_JVM_PERFORMANCE_OPTS="-server -XX:+UseG1GC -XX:MaxGCPauseMillis=20 -XX:InitiatingHeapOccupancyPercent=35
-XX:+ExplicitGCInvokesConcurrent -Djava.awt.headless=true"
 fi
 
+# version option
+for args in "$@" ; do
+  if [ "$args" = "--version" ]; then
+    exec $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS
$KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS "kafka.utils.VersionInfo"
+  fi
+done
 
 while [ $# -gt 0 ]; do
   COMMAND=$1
diff --git a/core/src/main/scala/kafka/utils/VersionInfo.scala b/core/src/main/scala/kafka/utils/VersionInfo.scala
new file mode 100644
index 0000000..3d42d4d
--- /dev/null
+++ b/core/src/main/scala/kafka/utils/VersionInfo.scala
@@ -0,0 +1,30 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package kafka.utils
+
+import org.apache.kafka.common.utils.AppInfoParser
+
+object VersionInfo {
+
+  def main(args: Array[String]) {
+    val version = AppInfoParser.getVersion
+    val commitId = AppInfoParser.getCommitId
+    System.out.println(s"${version} (Commit:${commitId})")
+    System.exit(0)
+  }
+}

-- 
To stop receiving notification emails like this one, please contact
jgus@apache.org.

Mime
View raw message