最近在学习 kafka ,搭建此处记录一下 mac 上 搭建 kafka 集群的搭建步骤。
由于 kafka 依赖 zookeeper 因此需要安装 zookeeper ,搭建而 kafka 是搭建基于 scala 语言编写, scala 又是搭建基于 jdk 的,因此需要安装 jdk 。搭建
ip客户端连接端口集群选举接口集群原子广播接口server.id中id的值节点名,目前没用到,这个配置到hosts文件中
注意:
1、下载 zookeeper 安装包
- get https://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.6.2/apache-zookeeper-3.6.2-bin.tar.gz
2、解压三份,并放置在 zookeeper 目录中
3、修改 zookeeper 配置文件,此处以 zk01 为例子
注意:
分别进入到 zk01/bin , zk02/bin , zk03/bin 目录下执行 如下命令
- ./zkServer.sh --config ../conf start
- ./zkCli.sh -server 127.0.0.1:2181,127.0.0.1:3181,127.0.0.1:4181
注意:
1、下载 kafka
- https://www.apache.org/dyn/closer.cgi?path=/kafka/2.6.0/kafka_2.13-2.6.0.tgz
2、解压3份,并放置到 kafka 目录中
3、修改 server.properties 文件,此处以 kafka01 为例子
需要修改的属性 ,此处以 kafka01 为示例,不同的接口修改具体的值
4、启动3个kafka节点
依次进入到 kafka01/bin , kafka02/bin , kafka03/bin 目录,执行如下命令
- ./kafka-server-start.sh ../config/server.properties &
5、kafka测试
1、创建一个主题
- bin/kafka-topics.sh --create --topic test-001 --replication-factor 1 --partitions 1 --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094
2、查看主题信息
- bin/kafka-topics.sh --describe --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094 --topic test-001
3、往创建的主题中发布一条信息
- bin/kafka-console-producer.sh --topic test-001 --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094
4、读取刚刚往主题中发布的消息
- bin/kafka-console-consumer.sh --topic test-001 --from-beginning --bootstrap-server 127.0.0.1:9092,127.0.0.1:9093,127.0.0.1:9094
到此,一个简单的可用的kafka集群就搭建完毕了。
责任编辑:未丽燕 来源: segmentfault.com Kafka集群节点(责任编辑:探索)
vivo创始人沈炜亮相国际手机产业领袖峰会,明确5G手机战略
30周年纪念4K重制《超级马里奥》真人电影将于9月15日重映
TGS23:SE开设TGS专题页面 带来《D勇者斗恶龙无限神速斩》等作
文投控股(600715.SH):北京文创定增基金已减持17.89万股 占公司总股份的0.0096%
《幻日夜羽:湛海耀光》最新角色系统情报 11月16日多平台发售
华兰生物(002007.SZ):2020年度净利升25.69% 基本每股收益0.8873元