Mac安装、配置并利用kafka。【保姆级简单教程】

kafka的安装与启动

1、安装

Mac版本可以在终端利用下令

1. brew install kafka

复制代码

安装过程会主动下载所需依赖，如zookeeper等

2、配置监听端口

kafka默认监听9092端口，所以如果单机部署，这一步可以跳过
打开配置文件

1. sudo vim /opt/homebrew/opt/kafka/bin/kafka-server-start /opt/homebrew/etc/kafka/server.properties

复制代码

新增
（下面下令选择其一，一样平常本地安装，选择第一个即可）

1. 本地：listeners=PLAINTEXT://:9092   
2. 指定IP: listeners=PLAINTEXT://xx.xx.xx.xx:9092

复制代码

3、启动

kafka依赖于zookeeper，所以启动时，应当先启动zookeeper
启动zookeeper

1. brew services start zookeeper

复制代码

启动kafka

1. brew services start kafka

复制代码

4、检查是否准确启动

实质为检查是否已经在监听9092端口

1. lsof -i :9092

复制代码

输出：

看到上面的输出，阐明我们已经准确监听9092端口。
5、下令利用用kafka

创建topic

1. kafka-topics --create --topic test --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092

复制代码

解释：
kafka-topics：用于管理主题。
–create：创建一个新的主题。
–topic test：主题的名称为 test。
–partitions 1：有 1 个分区（partition）。
–replication-factor 1：主题的副本因子为 1。体现没有冗余，数据仅存储在一个节点上。
–bootstrap-server localhost:9092：localhost:9092 体现 Kafka 服务器运行在本地主机的 9092 端口。
查察主题

1. kafka-topics --list --bootstrap-server localhost:9092

复制代码

订阅（消费者）
新建一个终端，输入

1. kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

复制代码

发布（生产者）
新建一个终端，输入

1. kafka-console-producer --bootstrap-server localhost:9092 --topic test

复制代码

接下来生产者所输入的信息，都会在消费者终端中显示

删除Topic

1. kafka-topics --delete --topic test --bootstrap-server localhost:9092

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。