没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
上海市长宁区古北路 666 号嘉麒大厦 22 楼
22F, 666 Gubei Road, Shanghai, China 200336
www.exands.com
多机环境搭建
操作系统:Centos 6
JDK版本:jdk1.8.0_121
Kafka版本:kafka_2.12-0.10.2.0
环境介绍:
以7台主机为例子:主机ip地址如:(host0、host1…host6)
配置说明:
host0、host1、…host4 // 作为集群的中心机器用来选举leader
host5、host6 // 作为观察者角色不参与选举,同样可进行数据通讯
为了性能考虑新加入的设备都采用观察者角色接入集群
一: 安装host0主机配置如下:
下载安装包如:kafka_2.12-0.10.2.0.tgz
下载地址:
http://kafka.apache.org/downloads
解压
tar -zxvf kafka_2.12-0.10.2.0.tgz
完成后配置文件路径:
/root/kafka_2.12-0.10.2.0/config
broker配置文件:server.properties
上海市长宁区古北路 666 号嘉麒大厦 22 楼
22F, 666 Gubei Road, Shanghai, China 200336
www.exands.com
1. 默认是0每一个broker在集群中的唯一,要求是正数。当该服务器的
IP地址发生改变时,broker.id没有变化,则不会影响consumers的消费情
况
broker.id=0
2. Kafka启动监听的host信息
advertised.listeners=PLAINTEXT://host0:9092
3. zookeeper集群的地址,可以是多个,多个之间用逗号分开,单机就
用本机地址
zookeeper.connect=host0:2181
4. 每个topic的分区个数,若是在topic创建时候没有指定的话会被topic
创建时的指定参数覆盖(exacds要求默认配置为256个分区)
num.partitions =256
5. 等待 IO 线程处理的请求队列最大数,若是等待 IO 的请求超过这个数
值,那么会停止接受外部消息,应该是一种自我保护机制。一般不会成为
瓶颈点,除非 I/O 性能太差,这时需要配合 num.io.threads 等配置一同进
行调整。
queued.max.requests =500
6. broker 处理磁盘 IO 的线程数,数值为 cpu 核数 2 倍
num.io.threads =8
7. broker 处理消息的最大线程数,一般情况下数量为 cpu 核数
剩余11页未读,继续阅读
资源评论
属你最帅
- 粉丝: 0
- 资源: 3
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功