courouge / kafka-monitor Goto Github PK

docker-compose up -d zookeeper-1 zookeeper-2 zookeeper-3
docker-compose up kafka-1 kafka-2 kafka-3

docker-compose up --build -d kadmin && docker-compose logs -f kadmin

 docker-compose exec zookeeper-1 bash -c 'echo stat |nc zookeeper-1 2181'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-topics --describe --zookeeper zookeeper-1:2181'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-topics --create --partitions 4 --replication-factor 3 --topic demo-perf-topic --zookeeper zookeeper-1:2181'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-producer-perf-test --throughput 500 --num-records 100000000 --topic demo-perf-topic --record-size 100 --producer-props bootstrap.servers=localhost:9092'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-consumer-perf-test --messages 100000000 --threads 1 --topic demo-perf-topic --broker-list localhost:9092 --timeout 60000'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-acls --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=zookeeper-1:2181 --add --allow-principal User:test --topic Test-topic'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-acls --authorizer kafka.security.auth.SimpleAclAuthorizer --authorizer-properties zookeeper.connect=zookeeper-1:2181 --list'

docker-compose exec kafka-1 bash -c 'KAFKA_OPTS="" kafka-producer-perf-test --throughput 500 --num-records 100000000 --topic demo-perf-topic --record-size 100 --producer-props bootstrap.servers=kafka-1:9092 --producer.config=/etc/kafka/secrets/producer.properties'

docker-compose exec mongodb bash -c 'mongo admin -u root -p rootpassword'

show dbs
show collections

use kafkamonitor
db.topics.find()

{ "_id" : "5e9c5e6007b9401756553735", "cluster" : "Cluster_100", "topic" : "__confluent.support.metrics", "size" : "11367", "time" : "2020-04-19T14:21:20.052Z" }