1.启动顺序

2.启动命令

2.1 启动zookeeper

/opt/kafka_2.11-1.0.0/bin/zookeeper-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/zookeeper.properties

-daemon （守护进程启动）

使用jps 查看是否启动

2.2 启动kafka-server

/opt/kafka_2.11-1.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/server.properties

2.3 查看已有主题

/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --list --zookeeper 192.168.224.130:2181

2.4 删除已有主题

/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --delete --zookeeper 192.168.224.130:2181 --topic test

2.5 创建新主题

/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --create --zookeeper 192.168.224.130:2181 --partitions 1 --replication-factor 1 --topic test

2.6 启动生产者-发送消息

/opt/kafka_2.11-1.0.0/bin/kafka-console-producer.sh --broker-list 192.168.224.130:9092 --topic test

2.7 启动消费者-拉取消息

/opt/kafka_2.11-1.0.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.224.130:9092 --topic test --from-beginning

--from-beginning 获取所有历史消息