---

提示：这里Kafka的版本是kafka_2.12-2.7.0。因Kafka没有提供version的命令，要查看版本可以进入到kafka/libs/目录下，可以看到像kafka_2.12-2.7.0.jar这样的文件，其中2.12是Scala版本，2.7.0是Kafka版本。

一、启动

下面启动命令都是在Kafka根目录下执行

cd /home/kafka/

1.启动Zookeeper（zk）

因为Kafka依赖于zk所以先启动zk
这里没有单独安装过zk用的是kafka/bin目录下自带的

nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties &

成功会返回进程号

也可以通过端口号查看状态

netstat -tunlp | grep 2181

2.启动Kafka

nohup ./bin/kafka-server-start.sh ./config/server.properties &

成功会返回进程号

二、生产与消费

1.创建topic

创建topic并命名为mytopic

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic

成功后会返回：Created topic mytopic.

查看下创建的所有topic

./bin/kafka-topics.sh --list --zookeeper localhost:2181

2.生产消息

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

这里写两条消息测试下（Ctrl+c可以退出）

3.消费消息

另开一个窗口来消费信息

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytopic --from-beginning

成功消费到

最后看看效果

---

总结

以上就是Linux下Kafka基本功能的实现，期待各位同僚对本文进行点评！