2017-10-11 11 views
2

다음 단계를 따라 Prometheus 및 Grafana로 kafka를 모니터링했습니다.Prometheus 및 Grafana로 kftka를 모니터링하십시오.

JMX 포트는 다음

wget http://ftp.heanet.ie/mirrors/www.apache.org/dist/kafka/0.10.1.0/kafka_2.11-0.10.1.0.tgz 
tar -xzf kafka_*.tgz 
cd kafka_* 

wget https://repo1.maven.org/maven2/io/prometheus/jmx/jmx_prometheus_javaagent/0.6/jmx_prometheus_javaagent-0.6.jar 
wget https://raw.githubusercontent.com/prometheus/jmx_exporter/master/example_configs/kafka-0-8-2.yml 

./bin/zookeeper-server-start.sh config/zookeeper.properties & 
KAFKA_OPTS="$KAFKA_OPTS -javaagent:$PWD/jmx_prometheus_javaagent-0.6.jar=7071:$PWD/kafka-0-8-2.yml" 
./bin/kafka-server-start.sh config/server.properties & 

을 열었다되지 내가 터미널에서 curl http://localhost:7071/metrics으로 확인했다

curl: (7) Failed connect to localhost:7071; Connection refused

현재

내가 내 네트워크에 내 모든 포트를 열어보고 서버.

netstat -tupln | grep LISTEN 포트 번호를 7071로 확인 메신저 아래

출력의 카프카 디렉토리의 내용입니다 목록에없는 동안 : 카프카 2181 포트와 사육사에서 실행되는

drwxr-xr-x. 3 root root 4096 Aug 23 12:22 bin 
drwxr-xr-x. 2 root root 4096 Oct 15 2016 config 
-rw-r--r--. 1 root root 20356 Aug 21 10:50 hs_err_pid1496.log 
-rw-r--r--. 1 root root 19432 Aug 21 10:55 hs_err_pid2447.log 
-rw-r--r--. 1 root root 1225418 Feb 5 2016 jmx_prometheus_javaagent-0.6.jar 
-rw-r--r--. 1 root root 2824 Aug 21 10:48 kafka-0-8-2.yml 
drwxr-xr-x. 2 root root 4096 Aug 21 10:48 libs 
-rw-r--r--. 1 root root 28824 Oct 5 2016 LICENSE 
drwxr-xr-x. 2 root root 4096 Oct 11 15:05 logs 
-rw-------. 1 root root 8453 Aug 23 12:08 nohup.out 
-rw-r--r--. 1 root root  336 Oct 5 2016 NOTICE 
drwxr-xr-x. 2 root root  46 Oct 15 2016 site-docs 

를 실행

답변

0

jmx 포트를 열어도 상관 없으면 다음과 같이 할 수도 있습니다.

export JMX_PORT=9999 
export KAFKA_JMX_OPTS=-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.rmi.port=9999' 
./bin/kafka-server-start.sh config/server.properties & 
java -jar jmx_prometheus_httpserver-0.10-jar-with-dependencies.jar 9300 kafka-0-8-2.yaml & 

source에서 mvn package으로 작성합니다.