Kafka 快速安装与使用
这篇文章是一篇Ubuntu(Linux)环境下的Kafka安装与使用教程,通过本文,你可以非常快速搭建一个kafka的小单元进行日常开发与调测。
安装步骤
1. 下载与解压安装首先我们需要下载一下Kafka的安装包,这里笔者采用的是通用的wget指令:
复制
wget https://downloads.apache.org/kafka/3.9.0/kafka_2.13-3.9.0.tgz1.
完成下载后将项目解压与重命名,方便后续的使用:
复制
tar -xzf kafka_2.13-3.9.0.tgz
mv kafka_2.13-3.9.0 kafka1.2.
因为笔者是在windows下的Linux子系统,为保证宿主机和子系统内部的Kafka可以准确连通,需打开config/server.properties文件,将ip改为你的对应主机IP确保以监听正确的网卡接受处理请求:
对应的配置参数如下,笔者只需将参数改为自己的ip地址即可:
复制
listeners=PLAINTEXT://x.x.x.x:9092
advertised.listeners=PLAINTEXT://x.x.x.x:90921.2.
完成上述步骤之后,键入如下指令即通过bin目录的zookeeper-server-start.sh将注册中心zookeeper启动,观测控制台启动是否无误,无误之后可以尝试后台启动,这里笔者为了文章的精简就不做过多演示了:
复制
./bin/zookeeper-server-start.sh config/zookeeper.properties1.
如下图,成功绑定2181后即可说明zk启动成功了:
同理将Kafka服务端启动即可:
复制
./bin/kafka-server-start.sh config/server.properties1.
经过上述的基本配置之后,我们已经成功的将kafka服务端启动了,以本文为例笔者的消费者会订阅transactions 这个topic,对应的启动指令为:
复制
./bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic 消费主题 --from-beginning1.
因为笔者服务器ip为172.19.182.7,且主题为transactions 所以对应的执行指令为:
复制
./bin/kafka-console-consumer.sh --bootstrap-server 172.19.182.7:9092 --topic transactions --from-beginning1.
确认无误后,启动一个topic为transactions的生产者投递消息,对应启动指令如下:
复制
./bin/kafka-console-producer.sh --broker-list 172.19.182.7:9092 --topic transactions1.
随后我们在生产者控制台键入hello consumer:
复制
>hello consumer1.
如下图,如果消费者接收消息成功,则说明本次kafka的基本配置与部署完成:
THE END