Current location - Trademark Inquiry Complete Network - Futures platform - Rocketmq configuration
Rocketmq configuration
Bok configuration file

The name of the cluster to which #broker belongs.

broker cluster name = rocket MQ-cluster

#broker name, each agent in the same cluster should have its own unique name.

Agent name = agent -a

# Set master broker and slave broker? Where 0 is the master and > 0 is the slave.

brokerId=0

#nameServer address (address is ip: port), and multiple addresses are separated by semicolons.

namesrvAddr = rocket MQ-name server 1:9876; Rocket MQ- Name Server 2:9876

# When sending a message, automatically create a theme that does not exist in the server, and the number of queues created by default.

defaultTopicQueueNums=4

# Allow Broker to automatically create themes, which can be opened for testing and closed for practical use?

autoCreateTopicEnable=true

# Do you allow Broker to automatically create subscription groups, which can be opened for testing and closed for practical use?

# If falsename is set during pull consumption, it will be reported that the subscription group does not exist, and no message will be received, which has no influence on push consumption.

autoCreateSubscriptionGroup = true

# Proxy listening port of external service

listen port = 109 1 1

Used for #haService

haListenPort= 109 12

# Mainly used to synchronize the host from.

fastListenPort= 10909

# Delete files regularly. The default time is 4 am.

Delete time =04

# By default, the maximum file retention time is 48 hours.

fileReservedTime= 120

#commitLog The default size of each file is1g.

mapedFileSizeCommitLog = 107374 1824

#ConsumeQueue each file has 30W entries by default, which will be adjusted according to business conditions.

mapedFileSizeConsumeQueue = 300000

# Force file deletion interval (ms)

# destroymappedfiletervalforcibly = 120000

# Periodically check the time interval between suspended files (milliseconds)

# redeletangedfileinterval = 120000

# Check the physical file disk space, and the disk space utilization rate cannot exceed 88%.

diskMaxUsedSpaceRatio=88

# Total storage path

storePathRootDir =/usr/local/rocket MQ/store

# Submit log storage path

storePathCommitLog =/usr/local/rocket MQ/store/commit log

# Consumption queue storage path storage path

storePathConsumeQueue =/usr/local/rocket MQ/store/consume queue

# Message index storage path

storePathIndex =/usr/local/rocket MQ/store/index

# Exception exits the generated file storage path.

store check point =/usr/local/rocket MQ/store/check point

# Abort file storage path

abort file =/usr/local/rocket MQ/store/abort

# Limit message size

maxMessageSize=65536

#Commitlog The minimum number of pages to be swiped at a time is 4kb per page.

flushCommitLogLeastPages = 4

#ConsumeQueue The maximum number of pages for each dish brushing, 4kb per page.

# flushConsumeQueueLeastPages = 2

# Dishwashing interval (ms). The priority of this interval is higher than the above two parameters, that is, when the time interval exceeds, the dishes will be washed directly, regardless of the number of pages.

# flushcomitlogthoroughinterval = 10000

# flushconsuqueueethoroughinterval = 60000

The role of #Broker (1) ASYNC_MASTER asynchronous replication master (2) SYNC_MASTER synchronous dual-write master (3) slave

brokerRole=ASYNC_MASTER

# Brush mode (1) ASYNC_FLUSH asynchronous brush? (2)SYNC_FLUSH synchronous disk brushing

flushDiskType=ASYNC_FLUSH

# Do you want to start the transaction check process? When the message volume is large, it may not be opened, and it is closed by default.

checkTransactionMessageEnable = false

# Number of messaging thread pools (16+ (core * thread) *4 if not configured)

# sendmessage threadpoolnums = 128

# Number of thread pools used to extract messages (if not configured, the number is 16+ (core * thread) *4)

# pullMessageThreadPoolNums = 12

Reference resource link

/Alibaba /rocketmq/store/config