[Bug] Subscription message serialization issue
Search before asking
- [x] #5209
Environment
Windows
EventMesh version
1.10.0
What happened
2025-09-25 06:50:30,709 ERROR [eventMesh-clientManage-4] HandlerService(HandlerService.java:325) - deserialize json string to typeReference error
org.apache.eventmesh.common.exception.JsonException: deserialize json string to typeReference error
at org.apache.eventmesh.common.utils.JsonUtils.parseTypeReferenceObject(JsonUtils.java:180) ~[eventmesh-common-1.10.0-release.jar:1.10.0-release]
at org.apache.eventmesh.runtime.core.protocol.http.processor.RemoteSubscribeEventProcessor.handler(RemoteSubscribeEventProcessor.java:122) ~[eventmesh-runtime-1.10.0-release.jar:1.10.0-release]
at org.apache.eventmesh.runtime.core.protocol.http.processor.HandlerService$HandlerSpecific.run(HandlerService.java:285) [eventmesh-runtime-1.10.0-release.jar:1.10.0-release]
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]
Caused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize value of type java.util.ArrayList<org.apache.eventmesh.common.protocol.SubscriptionItem> from String value (token JsonToken.VALUE_STRING)
at [Source: REDACTED (StreamReadFeature.INCLUDE_SOURCE_IN_LOCATION disabled); line: 1, column: 1]
at com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.DeserializationContext.reportInputMismatch(DeserializationContext.java:1767) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1541) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.DeserializationContext.handleUnexpectedToken(DeserializationContext.java:1488) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.deser.std.CollectionDeserializer.handleNonArray(CollectionDeserializer.java:402) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.deser.std.CollectionDeserializer._deserializeFromString(CollectionDeserializer.java:332) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.deser.std.CollectionDeserializer.deserialize(CollectionDeserializer.java:252) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.deser.std.CollectionDeserializer.deserialize(CollectionDeserializer.java:30) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.deser.DefaultDeserializationContext.readRootValue(DefaultDeserializationContext.java:342) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4917) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3860) ~[jackson-databind-2.18.0.jar:2.18.0]
at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3843) ~[jackson-databind-2.18.0.jar:2.18.0]
at org.apache.eventmesh.common.utils.JsonUtils.parseTypeReferenceObject(JsonUtils.java:178) ~[eventmesh-common-1.10.0-release.jar:1.10.0-release]
... 5 more
2025-09-25 06:50:36,063 INFO [EventMesh-TcpMetricsCalculator-scheduler-1] TcpMetricsCalculator(TcpMetricsCalculator.java:107) - ===================================
How to reproduce
Subscription message serialization issue
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 *
Welcome to the Apache EventMesh community!! We are glad that you are contributing by opening this issue. :D
Please make sure to include all the relevant context. We will be here shortly.
If you are interested in contributing to our project, please let us know! You can check out our contributing guide on contributing to EventMesh.
Want to get closer to the community?
| WeChat Assistant | WeChat Public Account | Slack |
|---|---|---|
![]() |
![]() |
Join Slack Chat |
Mailing Lists:
| Name | Description | Subscribe | Unsubscribe | Archive |
|---|---|---|---|---|
| Users | User support and questions mailing list | Subscribe | Unsubscribe | Mail Archives |
| Development | Development related discussions | Subscribe | Unsubscribe | Mail Archives |
| Commits | All commits to repositories | Subscribe | Unsubscribe | Mail Archives |
| Issues | Issues or PRs comments and reviews | Subscribe | Unsubscribe | Mail Archives |
Hi, I would like to work on this. Can you please assign me? Also, it would be great if you can add "How to reproduce" Thanks

