当前位置: 首页 > news >正文

KafKa02:Kafka配置文件server.properties介绍

一、配置文件位置

二、配置文件介绍

默认下:

  • 9092 是处理消息队列核心业务(客户端与 broker 交互)的端口
  • 9093 是集群内部控制器通信的端口
# 指定节点角色,这里同时作为 broker(消息代理)和 controller(控制器)
process.roles=broker,controller# 当前节点的唯一标识 ID
node.id=1# 控制器集群的投票节点列表,格式为 "nodeId@host:port",这里只有当前节点
controller.quorum.voters=1@localhost:9093
# 控制器集群的 bootstrap 服务器地址,用于节点发现控制器集群
controller.quorum.bootstrap.servers=localhost:9093# 节点监听的网络地址列表,PLAINTEXT 用于客户端和 broker 间通信,CONTROLLER 用于控制器间通信
listeners=PLAINTEXT://127.0.0.1:9092,CONTROLLER://127.0.0.1:9093# broker 之间通信使用的监听器名称
inter.broker.listener.name=PLAINTEXT# 对外公布的监听器地址(客户端实际连接的地址)
advertised.listeners=PLAINTEXT://localhost:9092,CONTROLLER://localhost:9093# 指定用于控制器通信的监听器名称
controller.listener.names=CONTROLLER# 监听器名称与安全协议的映射关系,这里都使用 PLAINTEXT(明文传输)
listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL# 处理网络请求的线程数
num.network.threads=3# 处理 I/O 操作的线程数
num.io.threads=8# 套接字发送缓冲区大小(字节)
socket.send.buffer.bytes=102400# 套接字接收缓冲区大小(字节)
socket.receive.buffer.bytes=102400# 允许的最大套接字请求大小(字节)
socket.request.max.bytes=104857600# 日志和数据存储目录
log.dirs=D:/Kafka/kafka_2.13-4.1.0/logs# 新建主题时的默认分区数
num.partitions=1# 每个数据目录用于日志恢复的线程数
num.recovery.threads.per.data.dir=1# 偏移量主题(__consumer_offsets)的副本因子
offsets.topic.replication.factor=1
# 消费者组协调器状态主题的副本因子
share.coordinator.state.topic.replication.factor=1
# 消费者组协调器状态主题的最小 ISR(同步副本)数量
share.coordinator.state.topic.min.isr=1
# 事务状态日志的副本因子
transaction.state.log.replication.factor=1
# 事务状态日志的最小 ISR 数量
transaction.state.log.min.isr=1# 日志保留时间(小时),超过此时间的日志会被删除
log.retention.hours=168# 单个日志段的最大大小(字节),达到此大小后会创建新的日志段
log.segment.bytes=1073741824# 日志保留检查的时间间隔(毫秒)
log.retention.check.interval.ms=300000

三、关键名词

broker:Kafka 服务器实例,负责存储消息和处理客户端请求。
controller:集群管理者,协调分区主从切换和元数据管理。
topic:消息的逻辑分类,用于区分不同类型的消息流。
分区:topic 的物理拆分,实现消息并行存储和处理。
生产者:向 Kafka topic 发送消息的客户端应用。
消费者:从 Kafka topic 读取消息的客户端应用。其中,Topic + 分区(Partition)的组合可以唯一标识 Kafka 中的一个 “物理消息队列”。
(配置文件中若选用默认的最大分区个数num.partitions=1,则可以简单理解为Topic 唯一对应一个物理消息队列)


文章转载自:

http://ViK3Tz4x.sjmxh.cn
http://yaU4zDuI.sjmxh.cn
http://1X6um9a9.sjmxh.cn
http://jpMKgGtS.sjmxh.cn
http://m8I5ZYhy.sjmxh.cn
http://B0cgbO9u.sjmxh.cn
http://KhwW5weK.sjmxh.cn
http://P5iPaEOY.sjmxh.cn
http://aI3ThZgO.sjmxh.cn
http://NdVqRoBF.sjmxh.cn
http://MAuXwH5z.sjmxh.cn
http://ITg7lf2w.sjmxh.cn
http://iN0DC1MG.sjmxh.cn
http://ELZMNvjq.sjmxh.cn
http://lSjcVQIR.sjmxh.cn
http://Y4E1jgXx.sjmxh.cn
http://s0WcT7vx.sjmxh.cn
http://7CjMr62E.sjmxh.cn
http://anXYij4b.sjmxh.cn
http://rrGinyEw.sjmxh.cn
http://aMXsFEoY.sjmxh.cn
http://Umeo8HPm.sjmxh.cn
http://z0AOMtFm.sjmxh.cn
http://oKMhFx9T.sjmxh.cn
http://1fkRZYIl.sjmxh.cn
http://72m1JudC.sjmxh.cn
http://WonPDXHP.sjmxh.cn
http://3QgvudlG.sjmxh.cn
http://243CHm0j.sjmxh.cn
http://GFiTGM52.sjmxh.cn
http://www.dtcms.com/a/380054.html

相关文章:

  • 【LeetCode 每日一题】3459. 最长 V 形对角线段的长度
  • Linux系统之----信号中断(下)
  • 【C++】模板进阶:非类型参数、模板特化与分离编译
  • 使用OmniAvatar-14B模型实现照片和文字生成视频的完整指南
  • Redis缓存雪崩
  • 复习Git在IDEA中的关键操作
  • IntelliJ IDEA git凭据帮助程序
  • 【Docker】P3 入门指南:运维与开发双重视角
  • Mac安装hadoop
  • 租房平台|租房管理平台小程序系统|基于java的租房系统 设计与实现(源码+数据库+文档)
  • Linux 深入理解权限
  • SQL Server 中的 STUFF 函数与FOR XML PATH详解
  • 配置自签证书多域名的动态网站+部署http的repo仓库+基于nfs与yum仓库的http部署
  • React学习教程,从入门到精通,React AJAX 语法知识点与案例详解(18)
  • Go语言详细指南:特点、应用场景与开发工具
  • vue el-cascader级联选择器-地区三级选择问题记录
  • 《机器人抓取:从经典到现代的综述》内容的提取和凝练:
  • 【ZEGO即构开发者日报】微信公众号上线“智能回复”功能;2025年8月中国应用/游戏厂商出海收入Top30榜;土耳其宣布将封禁29款社交/社媒应用……
  • qt QAreaLegendMarker详解
  • #C语言——刷题攻略:牛客编程入门训练(十三):循环输出图形(二)、一维数组(一),轻松拿捏!
  • Nginx服务——安装与搭建
  • 远程真机调试支持网络多线路切换,让自助兼容性测试更流畅
  • AI Agent工作流实用手册:5种常见模式的实现与应用,助力生产环境稳定性
  • 前端渲染技术全解析:SSR、SSG、CSR 有什么区别?
  • html css js网页制作成品——HTML+CSS娃娃店网页设计(4页)附源码
  • mac本地安装mysql
  • 使用android studio分析cpu开销
  • Android Studio如何开启离线编译模式
  • CSS 动画实战:实现电商中“加入购物车”的抛物线效果
  • Terraform整合到GitLab+Jenkins工具链