Apache EventMesh v1.10.0

Feature

• Feature #4011 add kafkaConnector module
• Feature #4032 Add Redis Connector modules
• Feature #4042 eventmesh operator
• Feature #4043 initial implementation of filter and transform
• Feature #4082 Support S3 file source connector
• Feature #4171 support pulsar connector
• Feature #4277 Add eventmesh-connector-knative
• Feature #4319 C SDK Framework
• Feature #4320 C SDK Support For TCP
• Feature #4328 Add offsetManagement Service for connectors
• Feature #4396 Realize the admin function for Kafka storage-plugin
• Feature #4409 Support source connector jdbc handle snapshot data for mysql
• Feature #4410 add wechat sink connector
• Feature #4411 Add DingDing sink connector.
• Feature #4412 Add WeCom sink connector.
• Feature #4415 Add Promethus source connector
• Feature #4419 Add slack sink connector.
• Feature #4439 Support source connector jdbc handle CDC for mysql
• Feature #4454 Support File Sink Connector
• Feature #4467 Rust SDK supports the latest gRPC protocol
• Feature #4513 Add eventmesh filter & transform sub module
• Feature #4519 Rust sdk support CloudEvents
• Feature #4577 Implement FilterEngine for EventMesh Filters
• Feature #4618 Add HTTP source connector
• Feature #4621 Implement TransformerEngine for EventMesh Transformer

Enhancement

• Enhancement #4096 InterruptedExceptions should never be ignored in the code.[EtcdMetaService]
• Enhancement #4178 When there are a large number of errors in the HTTP target, RocketMQ consumption is slow
• Enhancement #4222 support metadata management in http protocol
• Enhancement #4275 Support subscription info management with eventmesh-admin module
• Enhancement #4379 Enable manually commit offset in rocketmq source connector
• Enhancement #4388 Improve the rocketmq source connector offset ack
• Enhancement #4402 Refactor the retry module with HashedWheelTimer.
• Enhancement #4478 Upgrade JUnit to JUnit Jupiter
• Enhancement #4494 RESTful API framework for EventMeshAdmin
• Enhancement #4508 Add unit test for SpringSourceConnector.
• Enhancement #4510 Add test case for SpringSinkConnector.
• Enhancement #4515 Add test case for ProtocolPluginFactory.
• Enhancement #4530 Add unit test for RedisSourceConnector.
• Enhancement #4535 Add unit test for RocketMQSourceConnector.
• Enhancement #4536 Add unit test for RocketMQSinkConnector.
• Enhancement #4547 Add unit test for OpenFunctionSourceConnector.
• Enhancement #4568 Support adding extensions from ConnectRcord to CloudEvent
• Enhancement #4580 Connector extension supports spring environment variables.
• Enhancement #4590 WeCom/DingTalk connector extension supports spring environment variables
• Enhancement #4598 Improve eventmesh-connector-lark
• Enhancement #4665 Unify 'LiteMessage' to 'EventMeshMessage'

Bug

• Bug #4178 When there are a large number of errors in the HTTP target, RocketMQ consumption is slow
• Bug #4220 Fixes some bugs in eventmesh
• Bug #4236 TCP reconnection failed
• Bug #4245 Startup failed due to NullPointerException
• Bug #4286The response body is not recognised as JSON in query WebHook config endpoints
• Bug #4290 queryWebHookConfigByManufacturer endpoint causes NPE and unable to response
• Bug #4309 Http process error
• Bug #4345 Publish EventMeshMessage without requestCode throw java.lang.NullPointerException
• Bug #4346http demo AsyncPublishInstance test fail
• Bug #4350 Eventmesh startup failed under MQ plugin
• Bug #4354 fix spelling mistakes.
• Bug #4360http example unSubscribeUrl cannot be null
• Bug #4366When listens for remote nacos offset configuration, ConnectorRecordPartition deserialization fails
• Bug #4398 Should not use bash to excute sh script with CRLF in it and mis-output
• Bug #4403 Fix the SPI extension admin-api loading of storage-plugins
• Bug #4448 meta plugin dist startup failure
• Bug #4456 startup failure caused by Retryer
• Bug #4459 Unchecked call to a original type member
• Bug #4472 MeshMessageProtocolAdaptor#fromCloudEvent throw NPE
• Bug #4496 Gradle dist error
• Bug #4517 Webhook callback path is not a valid Nacos dataId
• Bug #4541 eventmesh-sdk-c make error for fail to make libcurl.a
• Bug #4585 The first-interaction ci check error
• Bug #4596 SourceWorker#convertRecordToEvent method converts ConnectRecord to CloudEvent throw NPE
• Bug #4602 when wechat send message api response errcode is not zero, the wechat sink connector does not throw IllegalAccessException
• Bug #4619 Grpc request reply can not work
• Bug #4623 CloudEvents variable names do not support underscores
• Bug #4625 Grpc request reply can not work-rust sdk
• Bug #4643 After crashing the runtime and restarting it, the grpc client will not be able to reconnect by sending heartbeat packets
• Bug #4647 The build binary package failed to run
• Bug #4652EventMeshGrpcConsumer subscribe webhook send heartBeat throw NP
• Bug #4659 HTTP source connector stop after receiving an invalid request
• Bug #4667 Some connectors have not been included in the package
• Bug #4670 Docker build failed due to a low JDK version
• Bug #4667 Some connectors have not been included in the package

Doc

• Doc #4182 Add JavaDoc for eventmesh-admin-rocketmq Module
• Doc #4185 Correct eventmesh.properties comment grammar mistake
• Doc #4208 Add JavaDoc for org.apache.eventmesh.runtime.admin APIs of dashboard
• Doc #4211 Add JavaDoc for eventmesh.runtime.admin APIs (not in dashboard)
• Doc #4559 Update connector readme doc file.
• Doc #4607 Documentation Needed for eventmesh-connector-rabbitmq
• Doc #4609 Documentation Needed for eventmesh-connector-mongodb
• Doc #4638 Sync connetor documents with website and optimize
• Doc #4656 Documentation Needed for eventmesh-connector-http
• Doc #4661 Documentation Needed for eventmesh-connector-slack
• Doc #4658 Documentation Needed for eventmesh-connector-dingtalk
• Doc #4663 Documentation Needed for eventmesh-connector-wecom
• Doc #4671 Update LICENSE and NOTICE