打开kafka服务器查看信息,Kafka与Zookeeper常用操作

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