rocketMQ4.9.2 不同broker之间的consumer offset没有同步,enableDLegerCommitLog=true #9216
zhongxiaoyi738
started this conversation in
General
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
[rocketmq@broker-01-68d4859b4d-b7gq7 bin]$ more /opt/conf/broker-01.conf
brokerClusterName = DefaultCluster
brokerName=broker-01
listenPort=31863
brokerIP1=10.7.30.237
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
maxMessageSize=65535
flushDiskType=ASYNC_FLUSH
deleteWhen=04
fileReservedTime=48
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=30000
diskMaxUsedSpaceRatio=88
storePathRootDir=/home/rocketmq/store/node00
storePathCommitLog=/home/rocketmq/store/node00/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n1-broker-01.rocketmq-flow.svc.cluster.local:40911;n2-broker-02.rocketmq-flow.svc.cluster.local:40911;n3-broker-03.rocketmq-flow.svc.cluster.local:40911
must be unique
dLegerSelfId=n1
sendMessageThreadPoolNums=16
[rocketmq@broker-02-84cc5b59fb-d2n2r bin]$ more /opt/conf/broker-02.conf
brokerClusterName = DefaultCluster
brokerName=broker-02
listenPort=31866
brokerIP1=10.7.30.237
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
maxMessageSize=65535
flushDiskType=ASYNC_FLUSH
deleteWhen=04
fileReservedTime=48
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=30000
diskMaxUsedSpaceRatio=88
storePathRootDir=/home/rocketmq/store/node00
storePathCommitLog=/home/rocketmq/store/node00/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n1-broker-01.rocketmq-flow.svc.cluster.local:40911;n2-broker-02.rocketmq-flow.svc.cluster.local:40911;n3-broker-03.rocketmq-flow.svc.cluster.local:40911
must be unique
dLegerSelfId=n2
sendMessageThreadPoolNums=16
[rocketmq@broker-03-584bb8879d-5b9tq bin]$ more /opt/conf/broker-03.conf
brokerClusterName = DefaultCluster
brokerName=broker-03
listenPort=31869
brokerIP1=10.7.30.237
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true
maxMessageSize=65535
flushDiskType=ASYNC_FLUSH
deleteWhen=04
fileReservedTime=48
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=30000
diskMaxUsedSpaceRatio=88
storePathRootDir=/home/rocketmq/store/node00
storePathCommitLog=/home/rocketmq/store/node00/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n1-broker-01.rocketmq-flow.svc.cluster.local:40911;n2-broker-02.rocketmq-flow.svc.cluster.local:40911;n3-broker-03.rocketmq-flow.svc.cluster.local:40911
must be unique
dLegerSelfId=n3
sendMessageThreadPoolNums=16
broker-02
#Topic #Group #Broker Name #QID #Broker Offset #Consumer Offset #Diff #LastTime
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-02 0 133 133 0 2025-01-19 14:43:05
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-02 1 121 121 0 2025-01-20 15:13:56
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-02 2 135 134 1 2025-01-19 14:43:05
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-02 3 121 121 0 2025-01-19 14:43:35
broker-03
#Topic #Group #Broker Name #QID #Broker Offset #Consumer Offset #Diff #LastTime
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-03 0 133 133 0 2025-01-19 14:43:05
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-03 1 121 121 0 2025-01-20 15:13:56
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-03 2 135 135 0 2025-02-27 16:39:54
ANALYSIS_TEMPLATE_TO_CARD_UPD ANALYSIS_TEMPLATE_TO_CARD_UPD broker-03 3 121 121 0 2025-01-19 14:43:35
Beta Was this translation helpful? Give feedback.
All reactions