Ответ 1

Не уверен, есть ли удобный способ, но вы можете просто проверить свою папку kafka/libs. Вы должны увидеть файлы типа kafka_2.10-0.8.2-beta.jar, где 2.10 - версия Scala, а 0.8.2-beta - версия Kafka.

Ответ 2

В данный момент нет ничего подобного kafka --version. Поэтому вы должны либо проверить версию в своей папке kafka/libs/, либо запустить

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

из вашей папки kafka (и он сделает то же самое для вас). Он вернет вам что-то вроде kafka_2.9.2-0.8.1.1.jar.asc, где 0.8.1.1 - ваша версия kafka.

Ответ 3

Существует несколько способов найти версию kafka

Метод 1 простой: -

ps -ef|grep kafka

отобразятся все запущенные клиенты kafka в консоли... Пример: -/usr/hdp/current/kafka-broker/bin/../libs/kafka-clients- 0.10.0.2.5.3.0-37.jar мы используем 0.10.0.2.5.3.0-37 версию kafka

Способ 2: -перейдите к

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

Пример: - kafka_2.10- 0.10.0.2.5.3.0-37.jar Кафка-clients- 0.10.0.2.5.3.0-37.jar

тот же результат, что и метод 1, мы можем найти версию kafka, использующую в kafka libs.

Ответ 4

Вы можете grep журналы, чтобы увидеть версию. Скажем, kafka установлен под /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)

покажет версию

Ответ 5

Кафка 2.0 имеет исправление (KIP-278) для этого:

kafka-topics.sh --version

Используя утилиту слияния:

Kakfa проверка версии может быть сделана с confluent утилитом, которая поставляется по умолчанию с платформой Confluent (confluent утилита может быть добавлена в кластер отдельно, а также - кредиты cricket_007).

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

Проверка версии других компонентов платформы Confluent, таких как ksql schema-registry и подключение

[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

Ответ 6

Простой способ на MacOS, например, установлен через homebrew

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

Ответ 7

перейти в папку kafka/libs мы можем видеть, что несколько банок ищут что-то подобное kafka_2.11-0.10.1.1.jar.asc, в этом случае версия kafka равна 0.10.1.1

Ответ 8

Когда вы устанавливаете Kafka в Centos7 с конфлюэнтом:

yum install confluent-platform-oss-2.11

Вы можете увидеть версию Kafka с помощью:

yum deplist confluent-platform-oss-2.11

Вы можете прочитать: confluent-kafka-2.11 >= 0.10.2.1

Ответ 9

Вы можете использовать для 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

Ответ 10

Вы также можете ввести

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

Ответ 11

Я просто набрал:

locate kafka | grep common-services

и получил 0.8.1:

/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/configuration/kafka-broker.xml
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/configuration/kafka-env.xml
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/configuration/kafka-log4j.xml
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka.py
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka.pyo
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.py
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/kafka_broker.pyo
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/setup_ranger_kafka.py
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/scripts/setup_ranger_kafka.pyo
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/templates/kafka.conf.j2
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/templates/kafka_client_jaas.conf.j2
/var/lib/ambari-agent/cache/common-services/KAFKA/0.8.1/package/templates/kafka_jaas.conf.j2
/var/lib/ambari-agent/cache/common-services/KAFKA/0.9.0/configuration/kafka-broker.xml
/var/lib/ambari-agent/cache/common-services/KAFKA/0.9.0/configuration/kafka-env.xml