-2 0/1 Pending 0 0s zk-2 0/1 Pending 0 0s zk-2 0/1 ContainerCreating 0 0s zk-2 0/1 Running 0 19s zk-2 1/1 Running -2 0/1 Pending 0 0s zk-2 0/1 Pending 0 0s zk-2 0/1 ContainerCreating 0 0s zk-2 0/1 Running 0 19s zk-2 1/1 Running Uncordon 第二个节点以允许 zk-2 被重新调度。
/kafka-console-consumer.sh --zookeeper zk-1:2181,zk-2:2181 --topic app.log ElasticSearch或者Kibana验证。 /kafka-topics.sh --describe --zookeeper zk-1:2181,zk-2:2181,zk-3:2181 --topic app.log 查看所有topic列表: sh kafka-topics.sh --zookeeper --zookeeper zk-1:2181,zk-2:2181,zk-3:2181 --list 创建topic sh kafka-topics.sh /bin/kafka-topics.sh --delete --zookeeper zk-1:2181,zk-2:2181,zk-3:2181 --topic app.log 生产topic的消息 . /kafka-console-consumer.sh --zookeeper zk-1:2181,zk-2:2181,zk-3:2181 --topic app.log 3.Kafka服务监控 通过以下命令启动了
apiVersion: v1 kind: ConfigMap metadata: name: zk-config namespace: kafka data: ensemble: "zk-0;zk-1;zk RESTARTS AGE zk-0 1/1 Running 0 6m28s zk-1 1/1 Running 0 5m48s zk <none> zk-1 1/1 Running 0 7m48s 172.10.2.46 node2 <none> <none> zk /etc/zookeeper/zoo.cfg Mode: leader kubectl exec zk-2 zkServer.sh status -n kafka ZooKeeper JMX enabled
不难证明有以下性质: (1) 如果am-1=bn-1,则zk-1=am-1=bn-1,且“z0,z1,…,zk-2”是“a0,a1,…,am-2”和“b0,b1,…,bn-2”的一个最长公共子序列;
address1=fc00::61/8 method=auto [proxy] 设置主机名 hostnamectl set-hostname zk-1 hostnamectl set-hostname zk