首先需要从官网上下载相关的二进制压缩包
https://kafka.apache.org/downloads
上面可以看出,分别提供了两个二进制版本供我们下载
2.12及2.13
从其中版本对应的链接中提供的方式选择一条,下载到本地
然后将其解压缩,并将目录放到机器上的某个文件夹下
tar -zxf kafka_2.12-3.2.0.tgz
cd kafka_2.12-3.2.0
然后启动服务器,需要拥有Java环境
不过在启动之前,仍然需要启动zookeeper,作为Kafka的协调服务器,对应的命令如下
bin/zookeeper-server-start.sh config/zookeeper.properties
然后启动Kafka服务器
bin/kafka-server-start.sh config/server.properties
创建一个Topic
这里我们创建一个只有一个分区,且此分区中只有一个副本的Topic
仍然利用bin中的shell脚本
bin/kafka-topics.sh –create –bootstrap-server localhost:9092 –topic test –partitions 1 –replication-factor 1
得到提示
之后查看对应的topic状态
获取到了topic的名称为test,分区数为1,副本数为1
之后是进行消息的发送和消费
我们首先创建一个消费者监听这个topic
bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from-beginning
并另外开启一个终端进行消息生产
bin/kafka-console-producer.sh –bootstrap-server localhost:9092 –topic test
接下来你再生产端输入的字符可以在消费者端看见
那么这就是一个简单的Kafka使用