// adjust topic partition kafka-topics --alter --topic ws-api --zookeeper zk-service --partitions 5
kafka-topics --alter --topic ws-gateway --zookeeper zk-service --partitions 5
// query topic status kafka-topics --topic ws-api -describe --zookeeper zk-service
kafka-topics --topic ws-gateway -describe --zookeeper zk-service
// query consumer group status kafka-consumer-groups --bootstrap-server kafka-service:9092 --describe --group ws-api-ee-release
kafka-consumer-groups --bootstrap-server kafka-service:9092 --describe --group ws-gateway-ee-release
|