一、简介
Apache Kafka是一个开源消息系统项目，由Scala写成。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。是一个分布式的、分区的、多复本的日志提交服务。它通过一种独一无二的设计提供了一个消息系统的功能。现在来实现一下部署到阿里云，并进行一些基本命令操作。
二、具体实现
1、官网下载kafka Binary包，这种包通过Scala 构建。可以直接启动。非这种包无法直接启动。我下载的是2.4.0版本。 地址：
Apache Kafka
2、通过scp命令上传下载的包到服务器
scp kafka_2.13-2.4.0.tgz root@bj0:/developer/
3、到达该目录解压
tar -zxvf kafka_2.13-2.4.0.tgz
4、到达解压目录，后台启动zookeeper
（1）daemon参数作用：守护进程，程序是一直运行的服务端程序，通常在系统后台运行，没有控制终端不与前台交互。
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
（2）启动以后，通过下面命令查看2181端口是否成功运行，zookeeper启动端口为2181。
netstat -tnlp | grep 2181
5、后台启动kafka
（1）同上，启动以后查看9092端口是否成功启动。
bin/kafka-server-start.sh -daemon config/server.properties
6、创建一个topic。
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092
7、展示topic的细节
bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
8、输入下面命令启动消费者
bin/kafka-console-consumer.sh --topic quickstart-events --bootstrap-server localhost:9092
9、打开另外一个窗口，打开生产者控制台发送一下消息到我们的主题
（1）我的2.4.0版本的kafka用这个命令
bin/kafka-console-producer.sh --topic quickstart-events --broker-list localhost:9092
（2）假如使用的是3.0左右的版本使用这个命令
bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
三、总结
以上就是在阿里云部署kafka的全部过程和一些命令，在这里记录一下，希望能够帮到大家，觉得不错的话，欢迎微信搜索关注java基础笔记，后面会不断更新相关知识，大家一起进步。
