#kafka数据的存放地址,多个地址的话用逗号分

log.dirs=/tmp/kafka-logs

#broker server服务端口

port=9092

#这个参数会在日志segment没有达到log.segment.bytes设置的大小,也会强制新建一个segment会被 topic创建时的指定参数覆盖

log.roll.hours=24

#是否允许控制器关闭broker ,若是设置为true,会关闭所有在这个broker上的leader,并转移到其他broker

controlled.shutdown.enable=false

#控制器关闭的尝试次数

controlled.shutdown.max.retries=3

#每次关闭尝试的时间间隔
controlled.shutdown.retry.backoff.ms=5000

#partition leader与replicas数据同步时,消息的队列

controller.message.queue.size=10

#partition leader与replicas之间通讯时,socket的超时时间

controller.socket.timeout.ms=30000

#是否允许自动创建topic,若是false,就需要通过命令创建topic

default.replication.factory=1

#表示消息体的最大大小,单位是字节

message.max.bytes=1000000

#broker处理磁盘IO的线程数,数值应该大于你的硬盘数

num.io.threads=8

#broker处理消息的最大线程数,一般情况下不需要去修改

num.network.threads=3

#每个topic的分区个数,若是在topic创建时候没有指定的话会被topic创建时的指定参数覆盖

num.partitions=1

#leader中进行复制的线程数,增大这个数值会增加relipca的IO

num.replica.fetchers=1

#ZooKeeper的连接超时时间

zookeeper.connection.timeout.ms=20000

其他参考:

转载于:https://www.cnblogs.com/yangsy0915/p/5933332.html

Kafka集群配置说明相关推荐

  1. 转-Kafka【第一篇】Kafka集群搭建

    转自: https://www.cnblogs.com/luotianshuai/p/5206662.html Kafka[第一篇]Kafka集群搭建 Kafka初识 1.Kafka使用背景 在我们大 ...

  2. kafka集群搭建(消息)

    1.Kafka使用背景 在我们大量使用分布式数据库.分布式计算集群的时候,是否会遇到这样的一些问题: 我们想分析下用户行为(pageviews),以便我们设计出更好的广告位 我想对用户的搜索关键词进行 ...

  3. Kafka集群部署CentOS 7

    一.前言 1.Kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件,同时Kafka也是一个流处理平台.Kakfa支持以发布/订阅的方式在应用间传递消息,同时并基于消息功能添加了Kafka ...

  4. zookeeper 和 kafka 集群搭建

    Kafka初识 1.Kafka使用背景 在我们大量使用分布式数据库.分布式计算集群的时候,是否会遇到这样的一些问题: 我们想分析下用户行为(pageviews),以便我们设计出更好的广告位 我想对用户 ...

  5. Zookeeper+Kafka集群搭建

    Zookeeper集群搭建 Kafka集群是把状态保存在Zookeeper中的,首先要搭建Zookeeper集群. 1.软件环境 (3台服务器-我的测试) 192.168.30.204 server1 ...

  6. java查看kafka集群状态_Linux系统 Kafka集群

    Kafka相关概念 Kafka的定义 它是一个分布式消息系统,由linkedin使用scala编写,用作LinkedIn的活动流(Activity Stream)和运营数据处理管道(Pipeline) ...

  7. java kafka 集群消费_kafka集群搭建和使用Java写kafka生产者消费者

    转自:http://chengjianxiaoxue.iteye.com/blog/2190488 1 kafka集群搭建 1.zookeeper集群 搭建在110, 111,112 2.kafka使 ...

  8. 打造全球最大规模 Kafka 集群,Uber 的多区域灾备实践

    - Uber 的 Kafka 生态系统 - Uber 拥有世界上最大的 Kafka 集群,每天处理数万亿条消息和几个 PB 的数据.如图 1 所示,Kafka 现在成了 Uber 技术栈的基石,我们基 ...

  9. 如何找到Kafka集群的吞吐量极限?\n

    Kafka是非常流行的分布式流式处理和大数据消息队列解决方案,在技术行业已经得到了广泛采用,在Dropbox也不例外.Kafka在Dropbox的很多分布式系统数据结构中发挥着重要的作用:数据分析.机 ...

最新文章

  1. 弱网测试用什么农_弱网测试(一)
  2. Jboot v2.0-rc.12 发布,优化细节问题
  3. 启动和停止MySQL服务
  4. Spring.net抛砖引玉系列(二)用接口来实现HelloWorld
  5. 微信小程序验证车牌号(含新能源车牌)
  6. 大话移动通信pdf_移动通信是怎么实现的?
  7. 存储mysql数据存在特殊字符时处理_SQL数据库对于保存特殊字符的解决办法
  8. 解题报告 Number
  9. jeewx 微信管家 - 举办商业版本免费试用活动
  10. pom文件报错,错误如下:(org.apache.maven.project.MavenProject,org.apache.maven.archiver.MavenArchiveConfigurat
  11. XSS的盲打以及实验的演示
  12. python颜色识别_python颜色识别
  13. Qt + 运动控制 (固高运动控制卡)【2】运动控制卡初始化和关闭
  14. WinRAR 6.0 永久去除广告
  15. Ubuntu常用软件合集
  16. 利用计算机金融诈骗,金融诈骗能追回钱款吗
  17. jQuery制作手风琴图片切换效果
  18. 部署Python的框架下的web app的详细教程
  19. python与会计学_Python 中用于表示逻辑与的关键字分别是 ____
  20. 计算机专业毕业设计答辩ppt案例,计算机专业 毕业设计答辩PPT.ppt

热门文章

  1. A Rectangular Barn
  2. java ibatis 锁表_oracle查看被锁的表和解锁
  3. shell5.0密钥_8.使用Xshell5密钥登录liunx
  4. 人名翻译_考研英语翻译:句子中出现人名怎么办?
  5. mysql乐观锁处理超卖_通过乐观锁解决库存超卖的问题
  6. 大根堆的删除c语言,二叉堆(一)之 C语言详解
  7. php mysql insert数组_PHP – MySQL编写的INSERT数组语句
  8. 计算机视觉 专业术语,计算机视觉专业相关术语中英文对照5
  9. netcore 图片 文件大小_NetCore 3.0文件上传和大文件上传的限制详解
  10. 0基础培训java必须掌握的一些知识点