一、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