zoukankan      html  css  js  c++  java
  • RocketMQ borker配置文件

    master节点:
    serverSelectorThreads = 3 brokerRole = SYNC_MASTER serverSocketRcvBufSize = 131072 osPageCacheBusyTimeOutMills = 1000 shortPollingTimeMills = 1000 clientSocketRcvBufSize = 131072 clusterTopicEnable = true brokerTopicEnable = true autoCreateTopicEnable = false maxErrorRateOfBloomFilter = 20 maxMsgsNumBatch = 64 cleanResourceInterval = 10000 commercialBaseCount = 1 maxTransferCountOnMessageInMemory = 32 brokerFastFailureEnable = true brokerClusterName = DefaultCluster flushDiskType = ASYNC_FLUSH commercialBigCount = 1 mapedFileSizeCommitLog = 1073741824 consumerFallbehindThreshold = 17179869184 autoCreateSubscriptionGroup = true transientStorePoolEnable = false flushConsumerOffsetInterval = 5000 waitTimeMillsInHeartbeatQueue = 31000 diskMaxUsedSpaceRatio = 75 cleanFileForciblyEnable = true slaveReadEnable = false flushCommitLogLeastPages = 4 expectConsumerNumUseFilter = 32 useEpollNativeSelector = false enablePropertyFilter = false messageDelayLevel = 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h deleteCommitLogFilesInterval = 100 brokerName = broker-1 maxTransferBytesOnMessageInDisk = 65536 mapedFileSizeConsumeQueue = 6000000 listenPort = 10911 flushConsumeQueueLeastPages = 2 pullMessageThreadPoolNums = 96 useReentrantLockWhenPutMessage = true flushIntervalConsumeQueue = 1000 sendThreadPoolQueueCapacity = 10000 debugLockEnable = false haHousekeepingInterval = 20000 diskFallRecorded = true messageIndexEnable = true clientAsyncSemaphoreValue = 65535 clientCallbackExecutorThreads = 40 putMsgIndexHightWater = 600000 sendMessageThreadPoolNums = 176 clientManagerThreadPoolQueueCapacity = 1000000 serverSocketSndBufSize = 131072 maxDelayTime = 40 clientSocketSndBufSize = 131072 namesrvAddr = 10.15.74.173:9876;10.15.64.134:9876;10.15.70.141:9876 commercialEnable = true maxHashSlotNum = 5000000 heartbeatThreadPoolNums = 32 transactionTimeOut = 3000 maxMessageSize = 4194304 adminBrokerThreadPoolNums = 16 defaultQueryMaxNum = 32 forceRegister = true maxTransferBytesOnMessageInMemory = 262144 enableConsumeQueueExt = false longPollingEnable = true serverWorkerThreads = 8 messageIndexSafe = false deleteConsumeQueueFilesInterval = 100 haSlaveFallbehindMax = 268435456 serverCallbackExecutorThreads = 0 flushCommitLogThoroughInterval = 10000 commercialTimerCount = 1 useTLS = false redeleteHangedFileInterval = 120000 flushIntervalCommitLog = 500 rocketmqHome = /home/service/app/rocketmq/ZAwgqBZNiiK_broker-1_0_10911/rocketmq-all-4.3.0-bin-release queryMessageThreadPoolNums = 48 messageStorePlugIn = serverChannelMaxIdleTimeSeconds = 120 maxIndexNum = 20000000 filterDataCleanTimeSpan = 86400000 filterServerNums = 0 commitCommitLogLeastPages = 4 waitTimeMillsInPullQueue = 5000 haSendHeartbeatInterval = 5000 clientChannelMaxIdleTimeSeconds = 120 filterSupportRetry = false flushDelayOffsetInterval = 10000 duplicationEnable = false offsetCheckInSlave = false clientCloseSocketIfTimeout = false transientStorePoolSize = 5 waitTimeMillsInSendQueue = 4200 warmMapedFileEnable = false flushCommitLogTimed = false flushLeastPagesWhenWarmMapedFile = 4096 clientWorkerThreads = 4 registerNameServerPeriod = 30000 registerBrokerTimeoutMills = 6000 accessMessageInMemoryMaxRatio = 40 highSpeedMode = false transactionCheckMax = 5 checkCRCOnRecover = true destroyMapedFileIntervalForcibly = 120000 brokerIP2 = 10.15.74.173 brokerIP1 = 10.15.74.173 commitIntervalCommitLog = 200 clientOnewaySemaphoreValue = 65535 traceOn = true clientManageThreadPoolNums = 32 channelNotActiveInterval = 60000 mappedFileSizeConsumeQueueExt = 50331648 consumerManagerThreadPoolQueueCapacity = 1000000 serverOnewaySemaphoreValue = 256 haListenPort = 10912 enableCalcFilterBitMap = false clientPooledByteBufAllocatorEnable = false storePathRootDir = /home/service/var/rocketmq_data/ZAwgqBZNiiK_broker-1_0_10911/data syncFlushTimeout = 5000 rejectTransactionMessage = false commitCommitLogThoroughInterval = 200 connectTimeoutMillis = 3000 queryThreadPoolQueueCapacity = 20000 regionId = DefaultRegion consumerManageThreadPoolNums = 32 disableConsumeIfConsumerReadSlowly = false flushConsumerOffsetHistoryInterval = 60000 fetchNamesrvAddrByAddressServer = false haTransferBatchSize = 819200 compressedRegister = false storePathCommitLog = /home/service/var/rocketmq_data/ZAwgqBZNiiK_broker-1_0_10911/data/commitlog commercialTransCount = 1 transactionCheckInterval = 60000 startAcceptSendRequestTimeStamp = 0 serverPooledByteBufAllocatorEnable = true serverAsyncSemaphoreValue = 64 heartbeatThreadPoolQueueCapacity = 50000 deleteWhen = 07;10;04;11 bitMapLengthConsumeQueueExt = 112 fastFailIfNoBufferInStorePool = false defaultTopicQueueNums = 8 notifyConsumerIdsChangedEnable = true flushConsumeQueueThoroughInterval = 60000 fileReservedTime = 24 brokerPermission = 6 transferMsgByHeap = true pullThreadPoolQueueCapacity = 100000 brokerId = 0 maxTransferCountOnMessageInDisk = 8
    slave节点:
    serverSelectorThreads = 3 brokerRole = SLAVE serverSocketRcvBufSize = 131072 osPageCacheBusyTimeOutMills = 1000 shortPollingTimeMills = 1000 clientSocketRcvBufSize = 131072 clusterTopicEnable = true brokerTopicEnable = true autoCreateTopicEnable = false maxErrorRateOfBloomFilter = 20 maxMsgsNumBatch = 64 cleanResourceInterval = 10000 commercialBaseCount = 1 maxTransferCountOnMessageInMemory = 32 brokerFastFailureEnable = true brokerClusterName = DefaultCluster flushDiskType = ASYNC_FLUSH commercialBigCount = 1 mapedFileSizeCommitLog = 1073741824 consumerFallbehindThreshold = 17179869184 autoCreateSubscriptionGroup = true transientStorePoolEnable = false flushConsumerOffsetInterval = 5000 waitTimeMillsInHeartbeatQueue = 31000 diskMaxUsedSpaceRatio = 75 cleanFileForciblyEnable = true slaveReadEnable = false flushCommitLogLeastPages = 4 expectConsumerNumUseFilter = 32 useEpollNativeSelector = false enablePropertyFilter = false messageDelayLevel = 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h deleteCommitLogFilesInterval = 100 brokerName = broker-1 maxTransferBytesOnMessageInDisk = 65536 mapedFileSizeConsumeQueue = 6000000 listenPort = 11011 flushConsumeQueueLeastPages = 2 pullMessageThreadPoolNums = 96 useReentrantLockWhenPutMessage = true flushIntervalConsumeQueue = 1000 sendThreadPoolQueueCapacity = 10000 debugLockEnable = false haHousekeepingInterval = 20000 diskFallRecorded = true messageIndexEnable = true clientAsyncSemaphoreValue = 65535 clientCallbackExecutorThreads = 40 putMsgIndexHightWater = 600000 sendMessageThreadPoolNums = 176 clientManagerThreadPoolQueueCapacity = 1000000 serverSocketSndBufSize = 131072 maxDelayTime = 40 clientSocketSndBufSize = 131072 namesrvAddr = 10.15.74.173:9876;10.15.64.134:9876;10.15.70.141:9876 commercialEnable = true maxHashSlotNum = 5000000 heartbeatThreadPoolNums = 32 transactionTimeOut = 3000 maxMessageSize = 4194304 adminBrokerThreadPoolNums = 16 defaultQueryMaxNum = 32 forceRegister = true maxTransferBytesOnMessageInMemory = 262144 enableConsumeQueueExt = false longPollingEnable = true serverWorkerThreads = 8 messageIndexSafe = false deleteConsumeQueueFilesInterval = 100 haSlaveFallbehindMax = 268435456 serverCallbackExecutorThreads = 0 flushCommitLogThoroughInterval = 10000 commercialTimerCount = 1 useTLS = false redeleteHangedFileInterval = 120000 flushIntervalCommitLog = 500 rocketmqHome = /home/service/app/rocketmq/ZAwgqBZNiiK_broker-1_1_11011/rocketmq-all-4.3.0-bin-release queryMessageThreadPoolNums = 48 messageStorePlugIn = serverChannelMaxIdleTimeSeconds = 120 maxIndexNum = 20000000 filterDataCleanTimeSpan = 86400000 filterServerNums = 0 commitCommitLogLeastPages = 4 waitTimeMillsInPullQueue = 5000 haSendHeartbeatInterval = 4000 clientChannelMaxIdleTimeSeconds = 120 filterSupportRetry = false flushDelayOffsetInterval = 10000 duplicationEnable = false offsetCheckInSlave = false clientCloseSocketIfTimeout = false transientStorePoolSize = 5 waitTimeMillsInSendQueue = 4200 warmMapedFileEnable = false flushCommitLogTimed = false flushLeastPagesWhenWarmMapedFile = 4096 clientWorkerThreads = 4 registerNameServerPeriod = 30000 registerBrokerTimeoutMills = 6000 accessMessageInMemoryMaxRatio = 40 highSpeedMode = false transactionCheckMax = 5 checkCRCOnRecover = true destroyMapedFileIntervalForcibly = 120000 brokerIP2 = 10.15.70.141 brokerIP1 = 10.15.70.141 commitIntervalCommitLog = 200 clientOnewaySemaphoreValue = 65535 traceOn = true clientManageThreadPoolNums = 32 channelNotActiveInterval = 60000 mappedFileSizeConsumeQueueExt = 50331648 consumerManagerThreadPoolQueueCapacity = 1000000 serverOnewaySemaphoreValue = 256 haListenPort = 11012 enableCalcFilterBitMap = false clientPooledByteBufAllocatorEnable = false storePathRootDir = /home/service/var/rocketmq_data/ZAwgqBZNiiK_broker-1_1_11011/data syncFlushTimeout = 5000 rejectTransactionMessage = false commitCommitLogThoroughInterval = 200 connectTimeoutMillis = 3000 queryThreadPoolQueueCapacity = 20000 regionId = DefaultRegion consumerManageThreadPoolNums = 32 disableConsumeIfConsumerReadSlowly = false flushConsumerOffsetHistoryInterval = 60000 fetchNamesrvAddrByAddressServer = false haTransferBatchSize = 32768 compressedRegister = false storePathCommitLog = /home/service/var/rocketmq_data/ZAwgqBZNiiK_broker-1_1_11011/data/commitlog commercialTransCount = 1 transactionCheckInterval = 60000 startAcceptSendRequestTimeStamp = 0 serverPooledByteBufAllocatorEnable = true serverAsyncSemaphoreValue = 64 heartbeatThreadPoolQueueCapacity = 50000 deleteWhen = 04;07;16;23 bitMapLengthConsumeQueueExt = 112 fastFailIfNoBufferInStorePool = false defaultTopicQueueNums = 8 notifyConsumerIdsChangedEnable = true flushConsumeQueueThoroughInterval = 60000 fileReservedTime = 24 brokerPermission = 6 transferMsgByHeap = true pullThreadPoolQueueCapacity = 100000 brokerId = 1 maxTransferCountOnMessageInDisk = 8
  • 相关阅读:
    Hystrix高可用系统容错框架,资源隔离,熔断,限流
    Leecode no.25 K 个一组翻转链表
    no.1 Web浏览器
    源码解析-JavaNIO之Buffer,Channel
    Leecode no.24 两两交换链表中的节点
    Kafka RocketMQ 是推还是拉?
    Leecode no.23 合并K个升序链表
    图解计算机底层IO过程及JavaNIO
    Leecode no.21 合并两个有序链表
    AcWing每日一题--摘花生
  • 原文地址:https://www.cnblogs.com/lwhctv/p/11941993.html
Copyright © 2011-2022 走看看