下载安装
从国内镜像站点下载并安装Kafka安装包，以下载并安装v3.2.3版本为例。
代码语言：javascript复制$ tar -xzf kafka_2.12-3.2.3.tgz
$ cd kafka_2.12-3.2.3启动服务
如下命令均在Kafka安装目录${KAFKA_HOME}下执行。
启动ZooKeeper服务：
$ bin/zookeeper-server-start.sh config/zookeeper.properties启动本地Kafka服务：
代码语言：javascript复制$ bin/kafka-server-start.sh config/server.properties执行操作
创建指定名称的Topic：
代码语言：javascript复制$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092查看指定Topic信息：
代码语言：javascript复制$ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092在控制台往指定Topic写入Kafka消息：
代码语言：javascript复制$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event这种方式写入Kafka的消息字符个数不能超过最大值4095，否则报错。 如果消息字符个数大于最大值，则可以将消息先按行分隔写入文件，然后再通过Linux管道命令写入Kafka。
代码语言：javascript复制$ vim test_kafka_events.txt
This is my first event
This is my second event
$ cat test_kafka_events.txt | bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092在控制台读取指定Topic中的消息：
代码语言：javascript复制$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second eventKafka相关完整文档详见：https://kafka.apache.org/documentation/ 。
