流程设计器配置,rocketmq发消息超时报错
错误处理 62
版本号:
镜像版本 harbor.oinone.top/oinone/oinone-designer-mini-v5.2:5.2.5.1
本地版本 5.2.5
错误信息:
io.netty.channel.ConnectTimeoutException: connection timed out: /172.16.20.126:10911
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:261) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:164) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at java.lang.Thread.run(Thread.java:750) ~[na:1.8.0_421]
2024-10-31 09:36:55.830 ERROR 468 --- [ sql.record] p.s.p.f.c.e.rocketmq.RocketMQTemplate : syncSendOrderly failed. destination:CHANGE_DATA_EVENT_TOPIC, message:GenericMessage [payload=Row{eventType=INSERT, schema='biz', table='simple_ex_home_sales', id=670537496911875082, pkNames=[], sql='null', before=[], after=[Column{name='area', value=杭州, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='writeUid', value=10001, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='productNum', value=6, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='id', value=670537496911875082, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='META_BIT', value=0, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='createUid', value=10001, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}], changeDate=null, env='null', tenant='', destination='null', executeTime=null, deloyTime=1730301065000}, headers={keys=null, topic=CHANGE_DATA_EVENT_TOPIC, tag=INSERT, id=e376bf63-c07a-7a48-e432-19a7fde738b2, PAMIRS_SESSION_KEY={"TRANSMITTABLE_EXTEND":"{}","KERNEL_EXTEND":"{}","REQUEST_VARIABLES":"pro.shushi.pamirs.meta.api.dto.protocol.PamirsRequestVariables#{\"requestInfoMap\":{\"checkStrategy\":\"RETURN_WHEN_COMPLETED\",\"msgLevel\":\"ERROR\"}}","DIRECTIVE":"0","STATIC_CONFIG":"false","SESSION_ID":"eaa22ef718d9435b9974b40302dc5463"}, timestamp=1730338612932}]
2024-10-31 09:36:55.840 ERROR 468 --- [ sql.record] p.s.p.f.c.e.r.RocketMQNotifyProducer : 发送消息异常
org.springframework.messaging.MessagingException: connect to 172.16.20.126:10911 failed; nested exception is org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 172.16.20.126:10911 failed
你的期望:
流程设计器配置模型新增触发,模型新增数据,能发起一条流程,通过本地服务入库
如何重现问题:
配置模型触发,场景新增的流程设计器
模型新增数据
-
mq有问题,namesrv和broker没有配对
broker.conf的内容配置如下
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
brokerIP1 = 127.0.0.1
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
transactionCheckInterval = 2000
transactionTimeOut = 20001个月前