hhuang1231 opened a new issue, #4567: URL: https://github.com/apache/eventmesh/issues/4567
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/eventmesh/issues?q=is%3Aissue) and found no similar issues. ### Question Currently I try to use connector-spring's soouce to send messages and then sink in DingTalk. 目前我尝试使用connector-spring的soouce来发送消息，然后在钉钉中下沉。 - Since DingTalk requires special extension fields, I first need to add `org.apache.eventmesh.connector.spring.source.connector.SpringSourceConnector#send(java.lang.Object, org.apache.eventmesh.openconnect.api. callback.SendMessageCallback)` method, add the required extension fields to `ConnectRecord` 由于钉钉需要特殊的扩展字段，所以我首先需要在`org.apache.eventmesh.connector.spring.source.connector.SpringSourceConnector#send(java.lang.Object, org.apache.eventmesh.openconnect.api.callback.SendMessageCallback)`方法，将需要的扩展字段添加进`ConnectRecord`中 - And due to CloudEvent's [name conventions](https://github.com/cloudevents/spec/blob/main/cloudevents/spec.md#naming-conventions), I also have to convert the `dingdingtemplatetypekey` to all lowercase before I can put it into the `extension` of `CloudEvent` 并且由于CloudEvent的[命名约束](https://github.com/cloudevents/spec/blob/main/cloudevents/languages/zh-CN/spec.md#naming-convention%E5%91%BD%E5%90%8D%E7%BA%A6%E5%AE%9A)，我也必须将`dingdingtemplatetypekey`转为全部小写，才能将其放入`CloudEvent`的`extension`中  - And had to modify the source code of `org.apache.eventmesh.openconnect.SourceWorker#convertRecordToEvent` so that it can get `extension` from `ConnectRecord` and add it to `CloudEvent` 并且不得不修改`org.apache.eventmesh.openconnect.SourceWorker#convertRecordToEvent`的源代码使其可以从`ConnectRecord`中得到`extension`并添加到`CloudEvent`中  - In addition, I found that sinkWoker will call `org.apache.eventmesh.openconnect.util.CloudEventUtil#convertEventToRecord` when receiving events, thereby completing the conversion from `CloudEvent`'s `extension` to `ConnectorRecord`'s `extension`, and sourceWoker But they didn't do this. Why? 另外我发现sinkWoker接收事件的过程中将会调用`org.apache.eventmesh.openconnect.util.CloudEventUtil#convertEventToRecord`，从而完成从`CloudEvent`的`extension`转换为`ConnectorRecord`的`extension`，而sourceWoker却没有这么做，这是为什么呢？  My doubts should be similar to #4560, and I hope to understand the community's current plans for this area. 我的疑惑与#4560 应该是类似的，我希望能够了解社区目前对于这一块的计划。 -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
