When there is no message, it will continue to print Exception raised during message reception

[CocytusElias]

When there is no message, my go client will keep printing ERROR Exception raised during message reception 40401 no new message

Is this expected? Can I control it from printing no message?

The rocket mq I deployed is a single namesrv, a single proxy, three broker masters and three broker slaves.

A single topic has 9 queues.

The client uses Go's PushConsumer, AwaitDuration is set to 300 sec, one consumer group is linked to one topic, ConsumptionThreadCount is 9, and MaxCacheMessageCount is 45

Below is the log：

2025-07-14T21:00:42.339+0800	INFO	[email protected]/push_consumer.go:395	Create standard consume service, consumerGroup=tai_shan_debezium_users_consumer, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:00:43.372+0800	INFO	[email protected]/push_consumer.go:440	Assignments of topic=tai_shan_debezium_users has changed, <nil> => &[message_queue:{topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}}], clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:00:43.372+0800	INFO	[email protected]/push_consumer.go:488	Start to fetch message from remote, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, clientId={}%!(EXTRA string=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j)	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:01:03.366+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=92c8954a-619b-4dbc-809f-0ba03479bfe2), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:01:03.386+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:01:23.379+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=681c9bfb-d616-4930-8cba-c23d998fd98e), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:01:23.401+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:01:43.380+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=3ea2cd62-4a93-4125-b827-f27cb66782ae), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:01:43.401+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:02:03.368+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=bcdcfdc5-0829-4ffe-b700-bf1844eec237), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:02:03.389+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:02:23.366+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=8b1b60c5-fefe-4130-a22b-30a90b2176e0), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:02:23.387+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:02:43.373+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=89166852-152b-4038-8f01-a5fd907b1e6b), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:02:43.394+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:03:03.378+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=4d320f52-18ac-4a24-bdbd-601342b73702), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:03:03.399+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:03:23.381+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=f982a3d5-2a8c-4966-b3c5-a7075dd7aeda), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:03:23.403+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:03:43.385+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=02f0a030-6794-442c-887b-482b2f0f8c7f), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:03:43.406+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:04:03.382+0800	ERROR	[email protected]/process_queue.go:442	Exception raised during message reception, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, endpoints=scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}, attemptId=%!d(string=e6b5bfe3-e199-462f-841e-4b037f40b852), nextAttemptId=, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j, err=%!w(*golang.ErrRpcStatus=&{40401 no new message})	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}
2025-07-14T21:04:03.403+0800	INFO	[email protected]/process_queue.go:480	Try to receive message later, mq=topic:{name:"tai_shan_debezium_users"}  id:-1  permission:READ_WRITE  broker:{name:"broker-a"  endpoints:{scheme:IPv4  addresses:{host:"192.168.1.102"  port:8101}}}, delay=20ms, clientId=CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j	{"client_id": "CocytusdeMacBook-Pro.local@41148@0@h97ihgzt4j"}

Below is the configuration information of broker a. Other brokers are similar to this one.

namesrvAddr=namesrv.rocket.svc.cluster.local:9876
brokerClusterName=CoreCluster
brokerName=broker-a
brokerId=0
brokerRole=ASYNC_MASTER

deleteWhen=04
fileReservedTime=120
flushDiskType=ASYNC_FLUSH
autoCreateTopicEnable=false
aclEnable=true


sendMessageThreadPoolNums=16
pullMessageThreadPoolNums=32
waitTimeMillsInSendQueue=50
waitTimeMillsInPullQueue=50
brokerFastFailureEnable=true
brokerFastFailureCleanAway=true
longPollingEnable=true
longPollingTimeout=300000

serverSelectorThreads=4
serverWorkerThreads=16     
useEpollNativeSelector=true

pullBatchSize=32
maxPullSize=128
filterServerNum=16

transferMsgByHeap=false
readOnlyCommitLog=true
mappedFileSizeCommitLog=1073741824

notifyConsumerIdsChangedEnable=true     
waitTimeMillsInRebalanceQueue=5000
clientManageThreadPoolNums=32