如何在 Linux 中找到卡夫卡版本

如何在 Linux 中找到卡夫卡版本? 是否有办法找到已安装的卡夫卡版本,而不是在下载时提及该版本?

258309 次浏览

不知道是否有一个方便的方法,但您可以只检查您的 kafka/libs文件夹。您应该会看到像 kafka_2.10-0.8.2-beta.jar这样的文件,其中 2.10是 Scala 版本,0.8.2-beta是卡夫卡版本。

在这一点上没有什么比 kafka --version更好的了。因此,您应该从 kafka/libs/文件夹中检查版本,或者您可以运行

find ./libs/ -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'

从你的卡夫卡文件夹(它也会为你做同样的事情)。它会返回一些像 kafka_2.9.2-0.8.1.1.jar.asc的东西,其中 0.8.1.1是你的卡夫卡版本。

你可以抓取日志来查看版本。假设卡夫卡安装在 /usr/local/kafka下,然后:

$ grep "Kafka version" /usr/local/kafka/logs/*


/usr/local/kafka/logs/kafkaServer.out: INFO Kafka version : 0.9.0.1 (org.apache.kafka.common.utils.AppInfoParser)

将会揭示这个版本

当你安装卡夫卡在 Centos7与汇合:

yum install confluent-platform-oss-2.11

你可以看到卡夫卡的版本:

yum deplist confluent-platform-oss-2.11

你可以阅读: confluent-kafka-2.11 > = 0.10.2.1

你也可以输入

cat /build.info

这会给你一个像这样的输出

BUILD_BRANCH=master
BUILD_COMMIT=434160726dacc4a1a592fe6036891d6e646a3a4a
BUILD_TIME=2017-05-12T16:02:04Z
DOCKER_REPO=index.docker.io/landoop/fast-data-dev
KAFKA_VERSION=0.10.2.1
CP_VERSION=3.2.1

进入卡夫卡/利布斯文件夹 我们可以看到多个 jar 搜索类似的 kafka _ 2.11-0.10.1.1.jar. asc,在这种情况下,kafka 的版本是0.10.1.1

有几种方法可以找到卡夫卡版本

方法1简单:-

ps -ef|grep kafka

它将显示所有运行的卡夫卡客户端在控制台..。 例如:-/usr/hdp/current/kafka-agent/bin/. ./libs/kafka-client-0.10.0.2.5.3.0-37. jar 我们使用的是0.10.0.2.5.3.0-37版本的卡夫卡

方法2:-

cd /usr/hdp/current/kafka-broker/libs
ll |grep kafka

例如:- 卡夫卡 _ 2.10-0.10.0.2.5.3.0-37. jar 卡夫卡-客户端 -0.10.0.2.5.3.0-37.jar

与方法1的结果相同,我们可以在卡夫卡库中找到卡夫卡的版本。

MacOS上的简单方法,例如通过 自酿的安装

$ ls -l $(which kafka-topics)
/usr/local/bin/kafka-topics -> ../Cellar/kafka/0.11.0.1/bin/kafka-topics

卡夫卡2.0有解决方案(KIP-278) :

kafka-topics.sh --version

或者

kafka-topics --version

使用汇合效用:

卡夫卡版本检查可以做与 confluent实用工具,这是默认与汇流平台(confluent实用程序可以单独添加到集群中-信用点 < a href = “ https://stackoverflow. com/users/2308683/cricket-007”> cricket _ 007 )。

${confluent.home}/bin/confluent version kafka

检查其他汇流平台组件的版本,如 Ksql 模式-注册表连接

[confluent-4.1.0]$ ./bin/confluent version kafka
1.1.0-cp1


[confluent-4.1.0]$ ./bin/confluent version connect
4.1.0


[confluent-4.1.0]$ ./bin/confluent version schema-registry
4.1.0


[confluent-4.1.0]$ ./bin/confluent version ksql-server
4.1.0

你可以使用 Debian/Ubuntu:

dpkg -l|grep kafka

预期结果应该是这样的:

ii  confluent-kafka-2.11                   0.11.0.1-1                                 all          publish-subscribe messaging rethought as a distributed commit log
ii  confluent-kafka-connect-elasticsearch  3.3.1-1                                    all          Kafka Connect connector for copying data between Kafka and Elasticsearch
ii  confluent-kafka-connect-hdfs           3.3.1-1                                    all          Kafka Connect connector for copying data between Kafka and Hadoop HDFS
ii  confluent-kafka-connect-jdbc           3.3.1-1                                    all          Kafka Connect connector for JDBC-compatible databases
ii  confluent-kafka-connect-replicator     3.3.1-1                                    all          Kafka Connect connector for replicating topics between Kafka clusters
ii  confluent-kafka-connect-s3             3.3.1-1                                    all          Kafka Connect S3 connector for copying data between Kafka and
ii  confluent-kafka-connect-storage-common 3.3.1-1                                    all          Kafka Connect Storage Common contains packages used by storage
ii  confluent-kafka-rest                   3.3.1-1                                    all          A REST proxy for Kafka

为了找到卡夫卡版本,我们可以使用 jps命令来显示机器上运行的所有 Java 进程。

步骤1: 假设您以 root 用户的身份运行 Kafka,那么使用 root 登录到您的机器并使用 jps -m。它将显示如下结果

4979 Jps -m
9434 Kafka config/server.properties

第二步: 根据上面的结果,你可以对卡夫卡应用程序进行 PID 控制,然后使用报告过程工作目录的 pwdx 9434。结果就像

9434: /apps/kafka_2.12-2.4.0

这里你可以看到卡夫卡的版本是2.12-2.4

我找到了一种不用搜索目录或日志文件就能做到这一点的简单方法:

kafka-dump-log --version

产出情况如下:

5.3.0-ccs (提交: 6481debc2be778ee)

检查卡夫卡版本:

cd /usr/hdp/current/kafka-broker/libs
ls kafka_*.jar

如果您想检查特定的卡夫卡代理的版本,请在代理上运行这个 CLI *

kafka-broker-api-versions.sh --bootstrap-server localhost:9092 --version

其中 localhost:9092是可访问的 <hostname|IP Address>:<port>,这个 API 将检查(如果在同一个主机上运行这个命令,可以使用 localhost)。输出示例:

2.4.0 (Commit:77a89fcf8d7fa018)

* Apache Kafka 在您的 Kafka 下载的 ./bin子目录中提供了各种控制台工具; 例如 ~/kafka/bin/

cd kafka

./bin/kafka-topics.sh --version

cd confluent-7.2.0/share/java/kafka

那么

$ ls -lha | grep kafka
-rw-r--r--  1 root root 5.3M Jul  5 09:45 kafka_2.13-7.2.0-ccs.jar
-rw-r--r--  1 root root 4.8M Jul  5 09:45 kafka-clients-7.2.0-ccs.jar
lrwxrwxrwx  1 root root   26 Jul 23 10:10 kafka.jar -> ./kafka_2.13-7.2.0-ccs.jar
-rw-r--r--  1 root root 9.4K Jul  5 09:45 kafka-log4j-appender-7.2.0-ccs.jar
-rw-r--r--  1 root root 458K Jul  5 09:45 kafka-metadata-7.2.0-ccs.jar
-rw-r--r--  1 root root 182K Jul  5 09:45 kafka-raft-7.2.0-ccs.jar
-rw-r--r--  1 root root  36K Jul  5 09:45 kafka-server-common-7.2.0-ccs.jar
-rw-r--r--  1 root root  84K Jul  5 09:45 kafka-shell-7.2.0-ccs.jar
-rw-r--r--  1 root root 151K Jul  5 09:45 kafka-storage-7.2.0-ccs.jar
-rw-r--r--  1 root root  23K Jul  5 09:45 kafka-storage-api-7.2.0-ccs.jar
-rw-r--r--  1 root root 1.6M Jul  5 09:45 kafka-streams-7.2.0-ccs.jar
-rw-r--r--  1 root root  41K Jul  5 09:45 kafka-streams-examples-7.2.0-ccs.jar
-rw-r--r--  1 root root 161K Jul  5 09:45 kafka-streams-scala_2.13-7.2.0-ccs.jar
-rw-r--r--  1 root root  52K Jul  5 09:45 kafka-streams-test-utils-7.2.0-ccs.jar
-rw-r--r--  1 root root 127K Jul  5 09:45 kafka-tools-7.2.0-ccs.jar