Apache EventMesh v1.9.0 发布，已支持轻量化事件连接器与 Openfunction 集成

EventMesh是一款开源的无服务器事件中间件，采用微内核插件化设计，具备丰富的开箱即用的事件连接器。它符合CNCF Serverlessworkflow标准的事件编排，支持标准的PubSub事件发布订阅模型，能够与不同的事件存储进行对接。在金融、互联网、制造、通信等行业都有广泛的应用案例。不论是物联网应用、实时数据处理、微服务架构还是事件驱动的分析系统，EventMesh都能帮助您构建强大、可靠且高效的系统。为企业实现数字化转型提供了应用进程间通信的全套解决方案，帮助企业降低系统复杂度，节约开发维护成本。

EventMesh v1.9.0 是从 Apache 孵化毕业后的第 1个版本，继 v1.8.0 版本提供了 Dashboard 与 workflow 的集成与交互能力后，本次版本最主要的功能特性是，新增了云原生事件连接器，通过轻量化的事件连接器，构建了事件在异构数据源间的流转通道，后续还可以通过 EventMesh Dashboard 对不同的事件连接器进行编排与配置。

除此之外，我们还进行了多项代码优化，修复了多个潜在的安全问题。详细的优化内容请查看下方。如果您对如何使用分布式应用框架提升效率，以及如何实现数据联合治理等话题有兴趣，欢迎加入我们的社区，了解更多解决方案的详细信息！

GitHub repo：https://github.com/apache/eventmesh

Gitee repo：https://gitee.com/WeBank/EventMesh

Website：https://eventmesh.apache.org/

微信群小助手 ID：EventMesh

EventMesh v1.9.0 特性

• 特性 #3805 Add EventMesh Connector API

• 特性 #3913 Add Source Connector RocketMQ Module

• 特性 #3920 Add Sink Connector RocketMQ Module

• 特性 #4123 Add EventMesh OpenFunction Source/Sink Connector

   

EventMesh v1.9.0 增强

• 增强 #3288 Refactor ConsumerGroupManager

• 增强 #3290 Refactor ConsumerManager

• 增强 #3323 Unsubscribe from a single topic

• 增强 #3339 Refactor EventMeshGrpcProducer

• 增强 #3485 Optimize Grpc protocol for Java

• 增强 #3870 Specifying the initial capacity of Map can save resources

• 增强 #3897 Admin, RocketMQAdmin, StandaloneAdmin and AbstractRmqAdmin can be more clearer.

• 增强 #3917 GrpcSummaryMetrics and TcpSummaryMetrics can share an parent class

• 增强 #3983 Optimize MessageQueue

• 增强 #4069 Add TLSConfig to registry plugin Consul.

• 增强 #4133 Optimize OpenFunctionSourceConnector poll

   

EventMesh v1.9.0 修复

• 漏洞 #3269 Load plugin failure

• 漏洞 #3271 Fix handle http message throw IllegalReferenceCountException

• 漏洞 #3273 Incorrect validation may cause the batch send of events to fail

• 漏洞 #3284 HTTP server HttpRequest release bug

• 漏洞 #3306 KafkaConsumerRunner Thread Closes Unexceptedly

• 漏洞 #3307 Kafka Consumer Closing Twice

• 漏洞 #3458 EventMeshHttpProducer publish Read timed out

• 漏洞 #3496 Can't build on jdk17

• 漏洞 #3595 Throw StorageResourceServiceKnativeImpl StorageResourceServiceKnativeImpl when start runtime with start.sh

• 漏洞 #3667 Rocketmq request callback timeout

• 漏洞 #3707 Thread leak exists when rocketmq consumer was shutdown

• 漏洞 #4141 GRPC subscribe error

• 漏洞 #4150 Fix ci compile error for JDK 11 in eventmesh-connector-openfunction

• 漏洞 #4144 Subscription is almost impossible to be cancelled when the TCP sub client is closed

• 漏洞 #4161 JsonUtils not support serialize java.time.LocalDate

• 漏洞 #4164 EventMeshGrpcConsumer client subscribe topic error

• 漏洞 #4166 AsyncPublishInstance has no push messages.