栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Kafka安装与配置

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Kafka安装与配置

1. 安装JDK 2. 安装Zookeeper

Zookeeper是安装Kafka集群的必要组件,Kafka通过Zookeeper来实施对元数据信息的管理,包括集群、broker、主题、分区等内容。

Zookeeper是一个开源的分布式协调服务。三个角色:leader、follower、observer,同一时刻Zookeeper集群中只有一个leader,其他的都是follower和observer,observer不参与投票,默认情况下只有leader和follower两个角色。

注意停掉防火墙:

[root@localhost etc]# cat redhat-release 
CentOS Linux release 7.9.2009 (Core)

[root@localhost zk-3.6.3]# service firewalld.service stop
Redirecting to /bin/systemctl stop firewalld.service

关键配置:

dataDir=/opt/soft/zookeeper/data

server.1=192.168.10.100:2888:3888
server.2=192.168.10.101:2888:3888
server.3=192.168.10.102:2888:3888

在dataDir目录下编辑myid文件,填写相应的id

3. 安装Kafka

下载后,修改config/server.properties,关键配置:

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://192.168.10.101:9092

# A comma separated list of directories under which to store log files
log.dirs=/opt/soft/kafka/logs

# Zookeeper connection string (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
# You can also append an optional chroot string to the urls to specify the
# root directory for all kafka znodes.
zookeeper.connect=192.168.10.100:2181/kafka,192.168.10.101:2181/kafka,192.168.10.102:2181/kafka

启动Kafka(前台方式),加入-daemon参数或者&后台运行

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

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/857857.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号