Kafka Zookeeper 基本命令示例

kafka 是消息队列处理消息的工具 

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-topic

# 新建Topic

# 

bin/kafka-topics.sh --list --zookeeper localhost:2181

# 查看已存在Topic列表

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-topic

# 查看指定Topic状态

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic my-topic --from-beginning

# 启动Consumer读取消息并输出到标准输出

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic

<< This is a messageThis is another message

  # 运行Producer并将Terminal输入的消息发送到服务端

bin/kafka-producer-perf-test.sh --messages 500000 --message-size 1000 --batch-size 500 --topics test --threads 2 --broker-list localhost:9092

bin/kafka-consumer-perf-test.sh --zookeeper localhost:2181 --messages 500000 --topic test --threads 1

# 性能测试

Zookeeper

bin/zkServer.sh start # 启动ZK服务

bin/zkServer.sh status # 查看ZK服务状态

bin/zkServer.sh stop # 停止ZK服务

bin/zkServer.sh restart # 重启ZK服务

bin/zkCli.sh -server 127.0.0.1:2181 # 连接服务器

ls / # 查看根目录

create /zk/testnode "test" # 创建 testnode节点

get /zk/testnode # 查看节点内容

set /zk/testnode test # 设置节点内容

delete /zk/testnode # 删除节点