这篇文章简单介绍如何在ubuntu上安装kafka，并使用kafka完成消息的发送和接收。

一、安装kafka

访问kafka官网Apache Kafka，然后点击快速开始

紧接着，点击Download

最后点击下载链接下载安装包

二、启动kafka

经过上一步下载完成后，按照页面的提示启动kafka

1、通过远程连接工具，如finalshell、xshell上传kafka_2.13-3.6.0.tgz到服务器上的usr目录

 

2、切换到usr目录，解压kafka_2.13-3.6.0.tgz

cd /usr

tar -zxzf kafka_2.13-3.6.0.tgz

 

3、启动zookeeper

修改配置文件confg/zookeeper.properties，修改一下数据目录

dataDir=/usr/local/zookeeper

然后通过以下命令启动kafka自带的zookeeper

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

4、启动kafka

修改配置文件confg/server.properties，修改一下kafka保存日志的目录

log.dirs=/usr/local/kafka/logs

然后新开一个连接窗口，通过以下命令启动kafka

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

 

三、kafka发送、接收消息

创建topic

bin/kafka-topics.sh --create --topic hello --bootstrap-server localhost:9092

 

生产消息

往刚刚创建的topic里发送消息，可以一次性发送多条消息，点击Ctrl+C完成发送

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

 

消费消息

新开一个连接窗口，在命令行输入以下命令拉取topic为hello上的消息

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic hello