一、Kafka操作
1.启动kafka命令：
#cd /opt/kafka_2.10-0.10.1.1/bin;
# ./kafka-server-start.sh /opt/kafka_2.10-0.10.1.1/config/server.properties &;
2.停止kafka命令：
# ./kafka-server-stop.sh
3.创建Topic：(创建一个名为test的topic，只有一个副本，一个分区。)
#./kafka-topics.sh –create –zookeeper 127.0.0.1:2181 –replication-factor 1 –partitions 1 –topic test
4.列出所有Topic：
#./kafka-topics.sh -list -zookeeper 127.0.0.1:2181
5.启动Producer并发送消息：
#./kafka-console-producer.sh –broker-list localhost:9092 –topic test
（输入相应的消息，eg:hello kafka;按Ctrl+C结束）
6.启动Consumer并接收消息：
#./kafka-console-consumer.sh –zookeeper 127.0.0.1:2181 –topic test –from-beginning
7.前台启动kafka：
./kafka-server-start.sh ../config/server.properties
8.后台启动kafka:
./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
9.指定监听端口
JMX_PORT=2898
./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &
二、Zookeeper常用操作
1.Zookeeper服务端启动：
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh start
2.Zookeeper服务端停止：
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh stop
3.Zookeeper服务端重启：
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh restart
4.查看Zookeeper进程：
#ps -ef|grep zookeeper;
5.查看Zookeeper服务端状态：
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh status
6.Zookeeper客户端登陆：
# cd /opt/zookeeper-3.4.10/bin/
#./zkCli.sh -server 127.0.0.1:2181
近期评论