BarryQian opened a new issue, #9959: URL: https://github.com/apache/seatunnel/issues/9959
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened The task successfully consumes messages from RocketMQ when it starts, but it fails after running for some time. ### SeaTunnel Version 2.3.12 ### SeaTunnel Config ```conf env { job.mode = "${job_mode}" parallelism = 1 job.name = "前端埋点数据" checkpoint.interval=60000 } source { Rocketmq { name.srv.addr = "${rocket_address}" topics = "b2c_front_track_report" start.mode = "${start.mode}" commit.on.checkpoint="${checkpoint}" partition.discovery.interval.millis = "600000" consumer.group = "b2c_front_track_report_group" ignore_parse_errors = true format = "json" format = json plugin_output = "source_track_report_data" schema = { fields { tenantCode = string siteId = string browserUniqId = string requestTs = string requestTime = string screenResolution = string osPlant = string deviceBrand = string ctPage = string ctRequestPar = string refPage = string refRequestPar = string sequenceNum = int visitTimes = int sessionId = string userLogAcct = string userVisitIp = string reportTs = string stmRt = int extColumns = string shopId = string skuId = string browserType = string browserVer = string recordCnt = int type = string pageId = string lang = string } } } } transform { FieldMapper { plugin_input = "source_track_report_data" plugin_output = "mapped_track_report_data" field_mapper = { tenantCode = tenant_code } } } sink { Jdbc { plugin_input = "target_track_report_table" url = "jdbc:mysql://${target_doris_address}" driver = "com.mysql.cj.jdbc.Driver" connection_check_timeout_sec = 100 user = "${target_doris_username}" password = "${target_doris_password:}" database = "b2c_bdm" table = "track_report" generate_sink_sql = true enable_upsert = false sql = "SELECT tenant_code FROM mapped_track_report_data" } } ``` ### Running Command ```shell sh /opt/seatunnel/bin/seatunnel.sh --config /export/servers/app/dp/task/bdm/sync_track_report.conf -i job_mode=Streaming -i rocket_address=rocketmq-nameserver:9876 -i checkpoint=true -i start.mode=CONSUME_FROM_GROUP_OFFSETS -i target_doris_address=doriscluster-fe-service:9030 -i target_doris_username=root -i target_doris_password= ``` ### Error Exception ```log [1031178795459018753] 2025-10-16 20:40:50,866 WARN [s.c.s.r.s.RocketMqSourceReader] [RocketMq Source Data Consumer] - Rocketmq consumer can not pull data, split MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=7], start offset 4726, end offset 4725 [1031178795459018753] 2025-10-16 20:40:50,866 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1031178795459018753, pipelineId=1, taskGroupId=2}] - [10.233.98.223]:5801 [seatunnel4hzj9] [5.1] Interrupted task 1000200000000 - org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@180ce53e [1031178795459018753] 2025-10-16 20:40:50,866 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1031178795459018753, pipelineId=1, taskGroupId=2}] - [10.233.98.223]:5801 [seatunnel4hzj9] [5.1] taskDone, taskId = 1000200000000, taskGroup = TaskGroupLocation{jobId=1031178795459018753, pipelineId=1, taskGroupId=2} [1031178795459018753] 2025-10-16 20:40:50,965 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1031178795459018753, pipelineId=1, taskGroupId=2}] - [10.233.98.223]:5801 [seatunnel4hzj9] [5.1] taskGroup TaskGroupLocation{jobId=1031178795459018753, pipelineId=1, taskGroupId=2} complete with CANCELED [1031178795459018753] 2025-10-16 20:40:50,965 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-3110] - [10.233.98.223]:5801 [seatunnel4hzj9] [5.1] Task TaskGroupLocation{jobId=1031178795459018753, pipelineId=1, taskGroupId=2} complete with state CANCELED [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-6a00968f-1065-4391-a07c-4f14b8753ee5@rocketmq-nameserver:9876-6a00968f-1065-4391-a07c-4f14b8753ee5@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=15] 4724 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-9d79853b-22c4-4a7b-8b39-a421bb842ba1@rocketmq-nameserver:9876-9d79853b-22c4-4a7b-8b39-a421bb842ba1@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=13] 4732 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-be69ee44-bc7d-4f4d-b92d-1df999e5dfa4@rocketmq-nameserver:9876-be69ee44-bc7d-4f4d-b92d-1df999e5dfa4@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=10] 4721 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-4a9fac8c-d71e-4f0d-8433-808b33d555e7@rocketmq-nameserver:9876-4a9fac8c-d71e-4f0d-8433-808b33d555e7@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=3] 4725 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-c53da799-5db9-4649-bae2-904489754fb3@rocketmq-nameserver:9876-c53da799-5db9-4649-bae2-904489754fb3@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=5] 4708 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-fe1c818d-d539-44c1-94d2-8a54517dcda7@rocketmq-nameserver:9876-fe1c818d-d539-44c1-94d2-8a54517dcda7@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=12] 4650 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-e3642376-a6ff-4291-8d2d-b2fa4de674cf@rocketmq-nameserver:9876-e3642376-a6ff-4291-8d2d-b2fa4de674cf@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=6] 4693 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-6052cd2a-6785-42f1-8e8c-6121985d99e9@rocketmq-nameserver:9876-6052cd2a-6785-42f1-8e8c-6121985d99e9@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=11] 4650 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-ce607895-866a-41ac-a8fa-c2f090f1ba47@rocketmq-nameserver:9876-ce607895-866a-41ac-a8fa-c2f090f1ba47@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=2] 4654 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-0923e131-ef56-4d8f-8c1e-5ab9cfdf0285@rocketmq-nameserver:9876-0923e131-ef56-4d8f-8c1e-5ab9cfdf0285@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=4] 4722 [1031178795459018753] 2025-10-16 20:40:50,965 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-3443bc4e-ef1c-44e1-b123-4497263d7fb2@rocketmq-nameserver:9876-3443bc4e-ef1c-44e1-b123-4497263d7fb2@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=9] 4726 [1031178795459018753] 2025-10-16 20:40:50,968 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-b7bcdf58-f9a7-4ccd-b4c1-6068c970980f@rocketmq-nameserver:9876-b7bcdf58-f9a7-4ccd-b4c1-6068c970980f@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=8] 4735 [1031178795459018753] 2025-10-16 20:40:50,968 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-6457077d-2504-455f-9d8c-b8b6b7f4f843@rocketmq-nameserver:9876-6457077d-2504-455f-9d8c-b8b6b7f4f843@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=1] 4709 [1031178795459018753] 2025-10-16 20:40:50,969 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-abd4f1f4-499b-4dfa-a0fc-71f323cfea53@rocketmq-nameserver:9876-abd4f1f4-499b-4dfa-a0fc-71f323cfea53@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=0] 4635 [1031178795459018753] 2025-10-16 20:40:50,969 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-d3b41fee-40d4-4713-a5ac-020417b1caab@rocketmq-nameserver:9876-d3b41fee-40d4-4713-a5ac-020417b1caab@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=7] 4726 [1031178795459018753] 2025-10-16 20:40:50,969 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - [persistAll] Group: b2c_front_track_report_group ClientId: 10.233.98.223@rocketmq-nameserver:9876-8625b48f-afc7-4031-94dd-680f04f7409d@rocketmq-nameserver:9876-8625b48f-afc7-4031-94dd-680f04f7409d@STREAM updateConsumeOffsetToBroker MessageQueue [topic=b2c_front_track_report, brokerName=broker-g0, queueId=14] 4655 [1031178795459018753] 2025-10-16 20:40:50,969 INFO [a.s.e.s.s.s.DefaultSlotService] [hz.main.generic-operation.thread-7] - received slot release request, jobID: 1031178795459018753, slot: SlotProfile{worker=[10.233.98.223]:5801, slotID=596, ownerJobID=1031178795459018753, assigned=true, resourceProfile=ResourceProfile{cpu=CPU{core=0}, heapMemory=Memory{bytes=0}}, sequence='995dbf65-32ba-48a4-959b-9d863acf2cc4'} [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,976 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [NettyClientPublicExecutor_1] - receive broker's notification[10.233.92.251:10911], the consumer group: b2c_front_track_report_group changed, rebalance immediately [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,977 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: null Consumer: b2c_front_track_report_group] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - the producer [CLIENT_INNER_PRODUCER] shutdown OK [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - Try to shutdown service thread:PullMessageService started:true lastThread:Thread[PullMessageService,5,main] [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - shutdown thread PullMessageService interrupt true [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - the producer [CLIENT_INNER_PRODUCER] shutdown OK [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - Try to shutdown service thread:PullMessageService started:true lastThread:Thread[PullMessageService,5,main] [1031178795459018753] 2025-10-16 20:40:50,978 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - shutdown thread PullMessageService interrupt true [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - the producer [CLIENT_INNER_PRODUCER] shutdown OK [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - Try to shutdown service thread:PullMessageService started:true lastThread:Thread[PullMessageService,5,main] [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - shutdown thread PullMessageService interrupt true [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqClient ] [PullMessageService] - PullMessageService service end [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - join thread PullMessageService elapsed time(ms) 0 90000 [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqClient ] [PullMessageService] - PullMessageService service end [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - join thread PullMessageService elapsed time(ms) 0 90000 [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: begin close the channel[10.233.92.251:10911] Found: true [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: the channel[10.233.92.251:10911] was removed from channel table [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: begin close the channel[10.233.45.118:9876] Found: false [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: the channel[10.233.45.118:9876] has been removed from the channel table before [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [NettyClientWorkerThread_2] - NETTY CLIENT PIPELINE: CLOSE 10.233.92.251:10911 [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [NettyClientWorkerThread_2] - eventCloseChannel: the channel[null] has been removed from the channel table before [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - shutdown thread NettyEventExecutor interrupt false [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - join thread NettyEventExecutor elapsed time(ms) 0 90000 [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group14] - closeChannel: begin close the channel[10.233.92.251:10911] Found: false [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group14] - closeChannel: the channel[10.233.92.251:10911] has been removed from the channel table before [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [NettyClientWorkerThread_1] - NETTY CLIENT PIPELINE: CLOSE 10.233.45.118:9876 [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [NettyClientWorkerThread_1] - eventCloseChannel: the channel[null] has been removed from the channel table before [1031178795459018753] 2025-10-16 20:40:50,979 WARN [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group14] - invokeSync: send request exception, so close the channel[10.233.92.251:10911] [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [NettyClientSelector_1] - closeChannel: close the connection to remote address[10.233.92.251:10911] result: true [1031178795459018753] 2025-10-16 20:40:50,979 ERROR [RocketmqClient ] [PullMsgThread-b2c_front_track_report_group14] - An error occurred in pull message process. org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <10.233.92.251:10911> failed [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqRemoting ] [NettyClientSelector_1] - closeChannel: close the connection to remote address[10.233.45.118:9876] result: true [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - unregister client[Producer: CLIENT_INNER_PRODUCER Consumer: null] from broker[broker-g0 0 10.233.92.251:10911] success [1031178795459018753] 2025-10-16 20:40:50,979 INFO [RocketmqClient ] [RocketMq Source Data Consumer] - the producer [CLIENT_INNER_PRODUCER] shutdown OK [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - Try to shutdown service thread:PullMessageService started:true lastThread:Thread[PullMessageService,5,main] [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - shutdown thread PullMessageService interrupt true [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqClient ] [PullMessageService] - PullMessageService service end [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - join thread PullMessageService elapsed time(ms) 0 90000 [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: begin close the channel[10.233.92.251:10911] Found: true [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: the channel[10.233.92.251:10911] was removed from channel table [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: begin close the channel[10.233.45.118:9876] Found: false [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - closeChannel: the channel[10.233.45.118:9876] has been removed from the channel table before [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqClient ] [PullMessageService] - PullMessageService service end [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [NettyClientWorkerThread_2] - NETTY CLIENT PIPELINE: CLOSE 10.233.92.251:10911 [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - shutdown thread NettyEventExecutor interrupt false [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [NettyClientWorkerThread_1] - NETTY CLIENT PIPELINE: CLOSE 10.233.45.118:9876 [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [RocketMq Source Data Consumer] - join thread NettyEventExecutor elapsed time(ms) 0 90000 [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [NettyClientWorkerThread_2] - eventCloseChannel: the channel[null] has been removed from the channel table before at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:441) ~[?:?] at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:390) ~[?:?] at org.apache.rocketmq.client.impl.MQClientAPIImpl.pullMessageSync(MQClientAPIImpl.java:779) ~[?:?] at org.apache.rocketmq.client.impl.MQClientAPIImpl.pullMessage(MQClientAPIImpl.java:733) ~[?:?] at org.apache.rocketmq.client.impl.consumer.PullAPIWrapper.pullKernelImpl(PullAPIWrapper.java:200) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pullSyncImpl(DefaultLitePullConsumerImpl.java:930) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pull(DefaultLitePullConsumerImpl.java:905) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pull(DefaultLitePullConsumerImpl.java:900) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.access$1400(DefaultLitePullConsumerImpl.java:77) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl$PullTaskImpl.run(DefaultLitePullConsumerImpl.java:849) ~[?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_342] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_342] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[?:1.8.0_342] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_342] [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqCommon ] [RocketMq Source Data Consumer] - join thread PullMessageService elapsed time(ms) 0 90000 [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [NettyClientWorkerThread_1] - eventCloseChannel: the channel[null] has been removed from the channel table before at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342] [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group7] - closeChannel: begin close the channel[10.233.92.251:10911] Found: false [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group7] - closeChannel: the channel[10.233.92.251:10911] has been removed from the channel table before [1031178795459018753] 2025-10-16 20:40:50,980 WARN [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group7] - invokeSync: send request exception, so close the channel[10.233.92.251:10911] [1031178795459018753] 2025-10-16 20:40:50,980 ERROR [RocketmqClient ] [PullMsgThread-b2c_front_track_report_group7] - An error occurred in pull message process. org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <10.233.92.251:10911> failed at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:441) ~[?:?] at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:390) ~[?:?] at org.apache.rocketmq.client.impl.MQClientAPIImpl.pullMessageSync(MQClientAPIImpl.java:779) ~[?:?] at org.apache.rocketmq.client.impl.MQClientAPIImpl.pullMessage(MQClientAPIImpl.java:733) ~[?:?] at org.apache.rocketmq.client.impl.consumer.PullAPIWrapper.pullKernelImpl(PullAPIWrapper.java:200) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pullSyncImpl(DefaultLitePullConsumerImpl.java:930) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pull(DefaultLitePullConsumerImpl.java:905) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.pull(DefaultLitePullConsumerImpl.java:900) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl.access$1400(DefaultLitePullConsumerImpl.java:77) ~[?:?] at org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl$PullTaskImpl.run(DefaultLitePullConsumerImpl.java:849) ~[?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_342] at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_342] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[?:1.8.0_342] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_342] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_342] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342] [1031178795459018753] 2025-10-16 20:40:50,981 WARN [RocketmqRemoting ] [PullMsgThread-b2c_front_track_report_group7] - invokeSync: send request exception, so close the channel[10.233.92.251:10911] [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [NettyClientSelector_1] - closeChannel: close the connection to remote address[10.233.92.251:10911] result: true [1031178795459018753] 2025-10-16 20:40:50,980 INFO [RocketmqRemoting ] [NettyClientSelector_1] - closeChannel: close the connection to remote address[10.233.45.118:9876] result: true ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
