RocketMQ-Broker配置参数

#接受客户端连接的监听端口,默认10911 listenPort=10911 #name server服务器地址及端口,可以是多个,分号隔开 namesrvAddr=192.168.1.100:9876 #当前 broker 监听的 IP,默认值 网卡的...

#接受客户端连接的监听端口,默认10911

listenPort=10911


#name server服务器地址及端口,可以是多个,分号隔开

namesrvAddr=192.168.1.100:9876


#当前 broker 监听的 IP,默认值 网卡的 InetAddress

brokerIP1=


#存在主从 broker 时,如果在 broker 主节点上配置了 brokerIP2 属性,broker 从节点会连接主节点配置的 brokerIP2 进行同步

brokerIP2=跟 brokerIP1 一样


#broker名称,用于主从配对,相同名称的broker才能做主从设置

brokerName=mq_broker_1


#broker集群名称,用于划分broker

brokerClusterName=MQCluster001


#用于标识主从关系,0为主,其他大于0的为从(不能小于0)master设置0,slave设置1。Master角色的Broker支持读和写,Slave角色的Broker仅支持读,也就是Producer只能和Master角色的Broker连接写人消息:Consumer可以连接Master角色的Broker,也可以连接Slave角色的Broker来读取消息。

#Master节点设置

brokerId=0

#Slave节点设置

#brokerId=1


#创建topic时,若未指定topic下的队列数,则取该默认值作为默认队列数

defaultTopicQueueNums=8


#是否自动创建默认topic,生产需保持关闭

autoCreateTopicEnable=true


#是否自动创建topic的订阅组,默认开启

autoCreateSubscriptionGroup=true


#未消费的持久化消息清理时间点,在每天的什么时间删除已经超过文件保留时间的 commit log

deleteWhen=04


#持久化消息保存周期(单位:小时),超过该周期将被清理

fileReservedTime=24


#单个commitLog文件的大小限制(单位:字节)

mapedFileSizeCommitLog=1073741824


#单个consumeQueue大小限制(存储的消息条数 * 每条消息的索引大小20)

mapedFileSizeConsumeQueue=8000000


#存储使用率阀值,当使用率超过阀值时,将拒绝发送消息请求

diskMaxUsedSpaceRatio=88


#持久化消息存储根路径,默认值 $HOME/store/

storePathRootDir=/data/store


#commitLog文件存储路径 默认值$HOME/store/commitlog/

storePathCommitLog=/data/store/commitlog


#存储 consume queue 的路径 默认值 $HOME/store/consumequeue/

storePathConsumerQueue=/data/store/consumequeue


#最大消息大小限制(单位:字节)

maxMessageSize=65536


#commitLog最少刷盘page数

flushCommitLogLeastPages=4


#consumeQueue最少刷盘page数

flushConsumeQueueLeastPages=2


#commitLog刷盘间隔时间

flushCommitLogThoroughInterval=10000


#consumeQueue刷盘间隔时间

flushConsumeQueueThoroughInterval=60000


#处理消息发送线程池大小

sendMessageThreadPoolNums=128


#处理消息拉取线程池大小

pullMessageThreadPoolNums=128


#broker角色(SYNC_MASTER:同步双写Master、ASYNC_MASTER:异步复制Master、SLAVE:Slave)

brokerRole=ASYNC_MASTER


#Slave节点设置

#brokerRole=SLAVE

#刷盘方式 SYNC_FLUSH/ASYNC_FLUSH 

#SYNC_FLUSH 模式下的 broker 保证在收到确认生产者之前将消息刷盘。

#ASYNC_FLUSH 模式下的 broker 则利用刷盘一组消息的模式,可以取得更好的性能。

flushDiskType=ASYNC_FLUSH


  • 发表于 2024-02-05 23:30
  • 阅读 ( 451 )

你可能感兴趣的文章

相关问题

0 条评论

请先 登录 后评论
shitian
shitian

662 篇文章

作家榜 »

  1. shitian 662 文章
  2. 石天 437 文章
  3. 每天惠23 33 文章
  4. 小A 29 文章