[Bug] Using the HTTP connector, data cannot be saved to RocketMQ after being pushed.

[likehao19]

Search before asking

• I had searched in the issues and found no similar issues.

Environment

Linux

EventMesh version

Other

What happened

Using the HTTP connector, data cannot be saved to RocketMQ after being pushed.

How to reproduce

Environment: EventMesh 1.12
Server: Linux x86
JDK: 1.17

Issue Description:
When using the HTTP connector, data cannot be saved to RocketMQ after being pushed.

Steps:

Enable source in server-config.yml:
sourceEnable: true
sinkEnable: false
Configure URL in source-config.yml:
pubSubConfig:
meshAddress: 127.0.0.1:10000
subject: TEST-TOPIC-SPRING
idc: FT
env: PRD
group: springSource
appId: 5033
userName: springSourceUser
passWord: springPassWord

connectorConfig:
connectorName: httpSource
path: /cdctest
port: 3755
idleTimeout: 30
protocol: CloudEvent
dataConsistencyEnabled: false
Configure in eventmesh.properties:
eventMesh.connector.plugin.type=rocketmq
Configure RocketMQ in rocketmq-client.properties (local instance):
eventMesh.server.rocketmq.namesrvAddr=127.0.0.1:9876
eventMesh.server.rocketmq.cluster=DefaultCluster
Start RocketMQ locally and create the topic.
Start the connector using the following command:
nohup java -cp "conf:plugin/connector/http/:apps/:lib/*"
org.apache.eventmesh.connector.http.server.HttpConnectServer \

logs/http-connector.log 2>&1 &
After startup, use an API tool to call:
http://:3755/cdctest

Connector Log Error:

2026-04-08 13:08:51,449 DEBUG [vert.x-eventloop-thread-0] ConnectionBase(:) - The connection will be closed due to timeout

Exception in thread "eventMesh-sourceWorker-pollService-1"
java.lang.NullPointerException: Cannot invoke
"org.apache.eventmesh.common.remote.offset.RecordPosition.getRecordPartition()"
because "position" is null

at org.apache.eventmesh.openconnect.offsetmgmt.api.data.RecordOffsetManagement.submitRecord(RecordOffsetManagement.java:55)
at org.apache.eventmesh.openconnect.SourceWorker.prepareToUpdateRecordOffset(SourceWorker.java:304)
at org.apache.eventmesh.openconnect.SourceWorker.startPollAndSend(SourceWorker.java:193)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:842)

Result:
Data is not saved to RocketMQ.

Debug logs

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct *