Odpowiedzi:
Nie ma nic takiego kafka --version
w tym momencie. Powinieneś więc albo sprawdzić wersję z kafka/libs/
folderu, albo uruchomić
find ./libs/ -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'
z twojego folderu kafka (i zrobi to samo dla ciebie). Zwróci ci coś takiego, kafka_2.9.2-0.8.1.1.jar.asc
gdzie 0.8.1.1
jest twoja wersja kafka.
/usr/local/kafka
find /usr/share/java/kafka -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'
find / -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'
Kafka 2.0 ma na to poprawkę ( KIP-278 ):
kafka-topics.sh --version
Sprawdzanie wersji Kakfa można przeprowadzić za pomocą confluent
narzędzia, które jest domyślnie dostarczane z platformą Confluent ( confluent
narzędzie można również dodać do klastra oddzielnie - kredyty cricket_007 ).
${confluent.home}/bin/confluent version kafka
Sprawdzanie wersji innych komponentów platformy Confluent, takich jak ksql schema-register i connect
[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
confluent version
nic ci nie jest.
Istnieje kilka metod wyszukiwania wersji kafka
Metoda 1 prosta: -
ps -ef|grep kafka
wyświetli wszystkie uruchomione klienty kafka w konsoli ... Np .: - /usr/hdp/current/kafka-broker/bin/../libs/kafka-clients- 0.10.0.2.5.3.0-37 .jar we używają wersji kafka 0.10.0.2.5.3.0-37
Metoda 2: - przejdź do
cd /usr/hdp/current/kafka-broker/libs
ll |grep kafka
Np .: - kafka_2.10- 0.10.0.2.5.3.0-37 .jar klienci-kafka- 0.10.0.2.5.3.0-37 .jar
taki sam wynik, jak w przypadku metody 1, możemy znaleźć wersję kafki używaną w bibliotekach kafka.
Możesz przeglądać dzienniki, aby zobaczyć wersję. Powiedzmy, że kafka jest zainstalowana pod /usr/local/kafka
, więc:
$ 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)
ujawni wersję
docker logs kafka | egrep -i "kafka\W+version"
Możesz użyć dla Debian / Ubuntu:
dpkg -l|grep kafka
Oczekiwany wynik powinien wyglądać następująco:
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
Podczas instalowania Kafki w Centos7 z konfluentem:
yum install confluent-platform-oss-2.11
Możesz zobaczyć wersję Kafki z:
yum deplist confluent-platform-oss-2.11
Możesz przeczytać: confluent-kafka-2.11> = 0.10.2.1
Aby znaleźć wersję Kafka, możemy użyć jps
polecenia, które pokazuje wszystkie procesy Java uruchomione na komputerze.
Krok 1: Powiedzmy, że korzystasz z Kafki jako użytkownik root, więc zaloguj się na swój komputer jako root i użyj jps -m
. Pokaże wynik jak
4979 Jps -m
9434 Kafka config/server.properties
Krok 2: Z powyższego wyniku możesz wziąć PID dla aplikacji Kafka i użyć, pwdx 9434
która raportuje bieżący katalog procesu. wynik będzie podobny
9434: /apps/kafka_2.12-2.4.0
tutaj możesz zobaczyć wersję Kafki 2.12-2.4.0
Aby sprawdzić wersję kafka:
cd /usr/hdp/current/kafka-broker/libs
ls kafka_*.jar
Jeśli chcesz sprawdzić wersję konkretnego brokera Kafka, uruchom ten interfejs CLI na tym brokerze *
kafka-broker-api-versions.sh --bootstrap-server localhost:9092 --version
gdzie localhost:9092
jest dostępny <hostname|IP Address>:<port>
ten interfejs API, który sprawdzi ( localhost
może być użyty, jeśli jest to ten sam host, na którym uruchamiasz to polecenie). Przykład wyniku:
2.4.0 (Commit:77a89fcf8d7fa018)
* Apache Kafka jest dostarczany z różnymi narzędziami konsoli w ./bin
podkatalogu pobierania Kafki; na przykład~/kafka/bin/
Możesz także wpisać
cat /build.info
To da ci taki wynik
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
/build.info
znajduje się w katalogu głównym kontenera