Kafak组件部署-单节点-简易文档

1，先启动Kafka自带的 Zookeeper

此时启动日志在 nohup.out 文件中

# 启动shell脚本
cd /usr/local/kafka_2.11-2.2.2
nohup bin/zookeeper-server-start.sh config/zookeeper.properties 2>&1 & 

2，启动默认的 Kafka

Kafak的日志目录是存储在 logs 目录中

# 启动shell脚本
cd /usr/local/kafka_2.11-2.2.2
nohup bin/kafka-server-start.sh config/server.properties 2>&1 & 

3，创建Topic

cd /usr/local/kafka_2.11-2.2.2
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo02

4，验证当前kafka集群中的topic

cd /usr/local/kafka_2.11-2.2.2
bin/kafka-topics.sh --list --zookeeper localhost:2181 

4，创建生产者

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

5,创建消费者

# 指定消息从头开始消费
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic demo02  --from-beginning

6.关闭所有程序的顺序

原则上是：按照启动顺序倒着关！！！

• 1.关闭 Consumer（直接 Ctrl+C）
• 2.关闭 Producer（直接 Ctrl+C）
• 3.关闭 Kafka

cd /usr/local/kafka_2.11-2.2.2
bin/kafka-server-stop.sh   config/server.properties

• 4.关闭 zookeeper

cd /usr/local/kafka_2.11-2.2.2
bin/zookeeper-server-stop.sh config/zookeeper.properties