Confluent-Platform

未分类

https://docs.confluent.io/current/installation/installing_cp/index.html

Confluent Platform and Apache Kafka Compatibility
https://docs.confluent.io/current/installation/versions-interoperability.html

平台检测

zookeeper(zk) 组件是否正常
docker exec $(docker ps | grep zookeeper | awk '{print $1}') cub zk-ready 127.0.0.1 3
docker exec $(docker ps | grep zookeeper | awk '{print $1}') zookeeper-shell 127.0.0.1:2181 ls /
docker exec $(docker ps | grep zookeeper | awk '{print $1}') bash -c "echo mntr | nc 127.0.0.1 2181" (关键)
docker exec $(docker ps | grep zookeeper | awk '{print $1}') bash -c "echo ruok | nc 127.0.0.1 2181"


kafka 组件是否正常
cub kafka-ready --help
cub kafka-ready -b 127.0.0.1:9092 1 8
cub kafka-ready -b `hostname`:9092 1 8
docker exec $(docker ps | grep kafka | awk '{print $1}') cub kafka-ready -b $(docker ps | grep kafka | awk '{print $1}'):9092 1 8
docker exec $(docker ps | grep kafka | awk '{print $1}') kafka-topics --zookeeper zk1 --describe --topic __confluent.support.metrics


schema_registry 组件是否正常
docker exec $(docker ps | grep schema | awk '{print $1}') cub sr-ready 127.0.0.1 8081 8 && echo $?
docker exec $(docker ps | grep schema | awk '{print $1}') curl -s --connect-timeout 2 --max-time 2 http://127.0.0.1:8081/config && echo