IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> Kafka集群参数配置说明 -> 正文阅读

[大数据]Kafka集群参数配置说明

Broker 端参数

# 指定了 Broker 需要使用的若干个文件目录路径。
# 在线上生产环境中一定要为log.dirs配置多个路径,最好目录挂在到不同的物理磁盘上。
# 1.可以提升读写性能,吞吐量更高。2.实现故障转移功能,将磁盘的数据转移到另一个上。
# 比如/home/kafka/data1,/home/kafka/data2,/home/kafka/data3
log.dirs: 

# 单个路径,它是补充上一个参数用的。一般不配置
log.dir: 

ZooKeeper 相关的设置

# 2181 是 ZooKeeper的默认端口
zookeeper.connect: zk1:2181,zk2:2181,zk3:2181
# 多个 Kafka 集群使用同一套ZooKeeper 集群,
zookeeper.connect: zk1:2181,zk2:2181,zk3:2181/kafka1

Broker 相关的设置

# 学名叫监听器,其实就是告诉外部连接者要通过什么协议访问指定主机名和端口开放的 Kafka 服务。
listeners: 

#listeners 相比多了个advertised。Advertised 的含义表示宣称的、公布的,就是说这组监听器是 Broker 用于对外发布的。
advertised.listeners:

监听器相关的设置

# 	它是若干个逗号分隔的三元组,每个三元组的格式为<协议名称,主机名,端口号>。这里的协议名称可能是标准的名字,
# 比如PLAINTEXT 表示明文传输、SSL 表示使用 SSL 或 TLS 加密传输等;也可能是你自己定义的协议名字
CONTROLLER: //localhost:9092。

# 一旦你自己定义了协议名称,你必须还要指定 listener.security.protocol.map参数告诉这个协议底层使用了哪种安全协议(表示CONTROLLER这个自定义协议底层使用明文不加密传输数据。)
listener.security.protocol.map=CONTROLLER:PLAINTEXT

# 最好全部使用主机名,即 Broker 端和 Client端应用配置中全部填写主机名。

Topic 管理配置

# 是否允许自动创建Topic。 参数我建议最好设置成false,即不允许自动创建 Topic。
auto.create.topics.enable: 

# 是否允许Unclean Leader 选举。 false 默认是 false,防止数据量少的备份副本进行选举
unclean.leader.election.enable: 

# 是否允许定期进行 Leader 选举。 建议设置 false,当一个leader用的好好的要定期强制切换leader也会有很大代价
auto.leader.rebalance.enable: 

数据留存配置

# 控制一条消息数据被保存多长时间。从优先级上来说 ms 设置最高、minutes 次之、hour 最低。
# 默认保存 7 天
log.retention.{hour|minutes|ms}: 

# 这是指定 Broker 为消息保存的总磁盘容量大小。
# 这个值默认是 -1 ,也就是说多少数据都可以。防止恶意传入数据,还是这只一下最大空间
log.retention.bytes: 

# 控制 Broker 能够接收的最大消息大小。
# 默认的 1000012 太少不到1MB ,所以建议扩容
message.max.bytes: 

Topic 级别参数

这里开始是在java.util.Properties类中配置
如果同时设置了 Topic 级别参数和全局 Broker 参数, Topic 级别参数会覆盖全局Broker 参数的值。

# 规定了该 Topic 消息被保存的时长。默认是 7 天,它会覆盖掉 Broker 端的全局参数值。
retention.ms

# 规定了要为该 Topic 预留多大的磁盘空间。 默认-1 不做限制
retention.bytes

创建 Topic 时进行设置
修改 Topic 时设置
可以设置他的具体配置

JVM 参数

这里在JVM启动参数中配置
kafka服务端代码是由Scala编写的,scala和java一样需要jvm虚拟机

# 指定堆大小。
KAFKA_HEAP_OPTS=--Xms6g --Xmx6g

# 指定 GC 参数。 XX:+UseParallelGC CPU资源不充裕时使用
KAFKA_JVM_PERFORMANCE_OPTS= -server XX:+UseCurrentMarkSweepGC

操作系统参数

文件描述符限制
文件系统类型
Swappiness
提交时间

ulimit -n

ulimit -n 1000000

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-03-17 22:14:33  更:2022-03-17 22:16:34 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 6:35:48-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码