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

Feature

• Feature #3805 Add EventMesh Connector API
• Feature #3913 Add Source Connector RocketMQ Module
• Feature #3920 Add Sink Connector RocketMQ Module
• Feature #4123 Add EventMesh OpenFunction Source/Sink Connector

Enhancement

• Enhancement #3288 Refactor ConsumerGroupManager
• Enhancement #3290 Refactor ConsumerManager
• Enhancement #3323 Unsubscribe from a single topic
• Enhancement #3339 Refactor EventMeshGrpcProducer
• Enhancement #3485 Optimize Grpc protocol for Java
• Enhancement #3870 Specifying the initial capacity of Map can save resources
• Enhancement #3897 Admin, RocketMQAdmin, StandaloneAdmin and AbstractRmqAdmin can be more clearer.
• Enhancement #3917 GrpcSummaryMetrics and TcpSummaryMetrics can share an parent class
• Enhancement #3983 Optimize MessageQueue
• Enhancement #4069 Add TLSConfig to registry plugin Consul.
• Enhancement #4133 Optimize OpenFunctionSourceConnector poll

Bug

• Bug #3269 Load plugin failure
• Bug #3271 Fix handle http message throw IllegalReferenceCountException
• Bug #3273 Incorrect validation may cause the batch send of events to fail
• Bug #3284 HTTP server HttpRequest release bug
• Bug #3306 KafkaConsumerRunner Thread Closes Unexceptedly
• Bug #3307 Kafka Consumer Closing Twice
• Bug #3458 EventMeshHttpProducer publish Read timed out
• Bug #3496 Can't build on jdk17
• Bug #3595 Throw StorageResourceServiceKnativeImpl StorageResourceServiceKnativeImpl when start runtime with start.sh
• Bug #3667 Rocketmq request callback timeout
• Bug #3707 Thread leak exists when rocketmq consumer was shutdown
• Bug #4141 GRPC subscribe error
• Bug #4150 Fix ci compile error for JDK 11 in eventmesh-connector-openfunction
• Bug #4144 Subscription is almost impossible to be cancelled when the TCP sub client is closed
• Bug #4161 JsonUtils not support serialize java.time.LocalDate
• Bug #4164 EventMeshGrpcConsumer client subscribe topic error
• Bug #4166 AsyncPublishInstance has no push messages.

Doc

• Doc #3453 There are no images used in the document.
• Doc #3942 Update README.zh-CN.md

Feature

• Feature #2888 Complete EventCatalog features
• Feature #2894 Complete Dashboard Workflow Features
• Feature #2865 Dashboard-add workflow swagger docs
• Feature #2866 Dashboard-add event catalog swagger docs
• Feature #2790 Jaeger tracing plugin docs
• Feature #2867 Dashboard-add workflow controller cmd module
• Feature #2868 Dashboard-add event catalog controller cmd module
• Feature #2808 Dashboard-Add event catalogs
• Feature #2807 Dashboard - Add Workflows
• Feature #2806 Dashboard - New style for the navigation menu
• Feature #2789 Jaeger tracing plugin service
• Feature #2788 Jaeger tracing plugin config

Enhancement

• Enhancement #2576 Enhancement the config manage for project
• Enhancement #2894 Optimize workflow save interface
• Enhancement #2880 Optimize workflow dashboard controller module
• Enhancement #2181 Workflow Feature Implementation: Catalog Management
• Enhancement #2180 Workflow Feature Implementation: Workflow Management
• Enhancement #2863 eventmesh-server-go module add golangci-lint command in Makefile
• Enhancement #2852 optimize code to reduce almost same code for updating client and subscription in different processor
• Enhancement #2702 Some optimizations for collections
• Enhancement #2693 SendAsyncEventProcessor judgment blanks can be simplified
• Enhancement #2691 Interface methods are public by default, so you can remove the public
• Enhancement #2642 go sdk common util module add testcase
• Enhancement #2640 Refine rabbitmq connector unit test
• Enhancement #2638 refactor go sdk id module test
• Enhancement #2196 Workflow Feature Implementation: Workflow execution metrics
• Enhancement #2190 Workflow Feature Implementation: Event Filter/Validate
• Enhancement #2192 Workflow Feature Implementation: Integrate EM, implement queue based on MQ

Bug

• Bug #2855 eventmesh-sdk-go test error
• Bug #2849 TCP Server will throw stack over flow error when subscribing because of calling self method recursively
• Bug #2845 Fix IOException in SSLContextFactory

Feature

• Feature #1553 Support rabbitmq connector
• Feature #1261 Support Pinpoint tracing plugin feature
• Feature #1248 Adds EventMesh Workflow Protocol
• Feature #1247 Adds EventMesh Catalog Protocol
• Feature #1244 Java SDK adds nacos naming selecotor
• Feature #1092 Java SDK adds EventMesh Catalog Client
• Feature #1091 Java SDK adds EventMesh Workflow Client
• Feature #1090 Support for managing EventMesh events using AsyncAPI
• Feature #1040 Support Pulsar connector plugin and Pulsar as event store
• Feature #973 zookeeper registry
• Feature #815 Support Rust
• Feature #790 Support Knative as Eventing Infra
• Feature #389 Support Redis
• Feature #270 Support another optional storage engine Pravega

Enhancement

• Enhancement #2167 Reliance on default encoding
• Enhancement #2169 Method checks the size of a collection against zero rather than using isEmpty() [WebhookTopicConfig]
• Enhancement #2147 add workflow run scripts
• Enhancement #2069 Support Go SDK Http EventMesh Message Protocol
• Enhancement #2062 Possible null pointer dereference due to return value of called method [SubScribeTask]
• Enhancement #2056 Use try-with-resources to manage resources [RejectClientByIpPortHandler]
• Enhancement #2017 Support Go SDK http protocol RR command
• Enhancement #2016 Possible null pointer dereference due to return value of called method [http SubController]
• Enhancement #2008 Support GO SDK Http protocol un-subscription
• Enhancement #2004 add workflow create command
• Enhancement #2002 Solve the project compile error
• Enhancement #1999 Refine rabbitmq connector unit test
• Enhancement #1993 Reliance on default encoding [WebhookFileListener]
• Enhancement #1983 Extract GO SDK protocol constant
• Enhancement #1934 upgrade workflow go.mod
• Enhancement #1933 optimize workflow-dal logic
• Enhancement #1932 optimize workflow-task logic
• Enhancement #1931 optimize workflow-jq logic
• Enhancement #1929 optimize workflow-catalog logic
• Enhancement #1928 upgrade workflow proto
• Enhancement #1927 add workflow examples demo
• Enhancement #1822 Support Go SDK producer message random sequence
• Enhancement #1743 Support Go SDK HTTP Client Load Balance
• Enhancement #1682 Java SDK add http connection pool
• Enhancement #1670 Add workflow mysql schema files
• Enhancement #1648 Modify worfklow scheduler config
• Enhancement #1636 Improve the performance of publish event in connector-pulsar
• Enhancement #1628 SSLContextFactory some config should configure in EventMeshHTTPConfiguration

Bug

• Bug #2163 This method needlessly uses a String literal as a Charset encoding [SendSyncMessageProcessor]
• Bug #2148 The webhook test occurs with an NPE
• Bug #1818 Fix IOException in SSLContextFactory
• Bug #1656 The extension field of CloudEvent does not exist.
• Bug #1654 Occur NullPointerException when broadcastEventListener consumes message
• Bug #1627 ConsumerGroup subscribes multiple topics, only first topic can invoke url
• Bug #1367 Cannot find the webhook protocol adaptor
• Bug #1350 Fix WebHookProcessorTest test error
• Bug #1347 Pravega connector writer doesn't close when unsubscribing
• Bug #1279 gradle.properties incorrect under the eventmesh-connector-pulsar
• Bug #1238 Can't start the pulsar connector
• Bug #1208 Use zipkin hippen NullPointerException
• Bug #1021 Span is null when eventMeshServerTraceEnable is false
• Bug #1022 Two NPE problems with Tcp Protocol Resolver
• Bug #1035 Tcp UpStreamMsgContext retry infinite loop
• Bug #1036 The bug caused by the logical sequence of tcp closeSession
• Bug #1038 The result of validate target url method is opposite in http protocol
• Bug #1052 Only the first instance of the same consumer group receives the message in http protocol
• Bug #1056 Fix StringIndexOutOfBoundsException
• Bug #1059 NullPointException of Http Request
• Bug #1064 NullPointException Of ClientManageControllerTest
• Bug #1074 Fix PrometheusConfigurationTest running test fail

Document and code style improvement

• Document #2074 Update Pravega connector doc
• Document #2066 Optimize http-demo zh document
• Document #1520 Update the eventmesh keywords.
• Document #1500 Fix the readme file.
• Document #1496 error words in 03-demo.md
• Document #1368 Knative Connector: Move Documentation to Design Directory
• Document #1271 Translation of documents [webhook.md]
• Document #1246 Pravega connector doc
• Document #1213 Support Knative as Eventing Infra: Documentation (Publish/Subscribe)

Feature

• Feature #866 Support webhook
• Feature #901 Support consul registry
• Feature #1029 Support etcd registry

Enhancement

• Enhancement #1005 Remove some invalid imports
• Enhancement #1015 Made some fields are final

Bug

• Bug #980 The fields need to be made final
• Bug #997 ProducerGroupConf#equals doesn't work
• Bug #1021 Span is null when eventMeshServerTraceEnable is false
• Bug #1022 Two NPE problems with Tcp Protocol Resolver
• Bug #1035 Tcp UpStreamMsgContext retry infinite loop
• Bug #1036 The bug caused by the logical sequence of tcp closeSession
• Bug #1038 The result of validate target url method is opposite in http protocol
• Bug #1052 Only the first instance of the same consumer group receives the message in http protocol
• Bug #1056 Fix StringIndexOutOfBoundsException
• Bug #1059 NullPointException of Http Request
• Bug #1064 NullPointException Of ClientManageControllerTest
• Bug #1074 Fix PrometheusConfigurationTest running test fail

Document and code style improvement

• Document #1006 Outdated instruction docs (CN)
• Document #1033 Update docs of quick-start
• Document #1068 Translate the design document (cloudevents.md)

Feature

• Support golang sdk
• Add consumer, producer, heartbeat
• Add msg dispatcher on rece msg from mesh server
• Add go client api
• Add fake server for go sdk test
• Add go sdk example
• Support nacos registry
• Add WatchDirectoryTask and add file watch listener and manager
• Add ttl default value when building BatchMessage
• Http request improve support request uri for http processors
• Support http protocol adaptor
• Support event bridge pub/sub
• Add the eventmesh metadata to nacos
• Add trace buried point for EventmeshTcpServer in eventmesh-runtime

BugFix

• Could not find or load main class by test script
• Darwin operating system detection bug fix
• Fix LocalSubscribeEventProcessor json deserialize error
• Fix the key when removing item from ClientGroupMap

Improvement

• Remove tool directory
• Lint the documentations with markdownlint
• Update bug_report.yml, fix typo
• Updated slack invite link in README
• Removed redundant code
• Optimized documentation docker script code blocks
• Upgrade spring libs & jackson-databind s version to fix CVEs issues
• Update ci.yml enable codecov
• Upgrade rocketmq libs version to fix CVEs
• Removed PropertyConst.java
• Remove some useless classes from eventmesh-common.
• Clean up some useless constants and classes.
• Add test code for module [eventmesh-trace-plugin]
• Add files via upload
• Transitively export the dependencies of [eventmesh-sdk-java] to other module
• Add the unit guidelines document and issue template
• Add the unit test document link and modify the unit test issue template
• Rewrite the English documentation
• Format the code in eventmesh-sdk-java and eventmesh-common
• Rewrite README.md and fix errors in the documentation
• Delete unnecessary shadow plugin
• Add unit test for sdk java
• Delete already defined java-library plugin and make lombok compileOnly
• Adapt unit tests to JDK 8
• Guide of EventMesh Java SDK
• Avoid setting the value of the field by reflection in the unit test.
• Add unit tests for EventMesh SDK for Java
• Remove unused methods in EventMesh-Connector-Api Producer interface
• Update Chinese version of README.md
• Add new contributor doc that have been reorganized
• Update em host in example
• Update licenserrc.yaml to ignore go.sum
• Add http request doc instruction
• Add remote processors for event bridge
• Code optimization
• Registry plugin is disabled by default
• Optimize trace module in eventmesh
• Check whether the registry is enabled

All pull request are here

Feature

• Feature #417 A lightable full-featured polyglot capability support

Enhancement

• Enhancement #809 eventmesh trace-zipkin plugin miss the properties
• Enhancement #780 EventListener defines in the level of Consumer may be more proper instead of the level of topic
• Enhancement #774 Remove prodcerGroup and consumerGroup fields in UserAgent, which are strongly related with MQ
• Enhancement #758 Validate the Url parameter in Http Subscriber
• Enhancement #742 missing necessary jar when build deploy package
• Enhancement #735 Update log4j to 2.17.1 (or newer)
• Enhancement #696 improve the metrics/tracing exporters' expandability

Bug

• Bug #768 HTTP Subscriber: Updating subscription information is not taking effect
• Bug #756 upgrade commons-validator as v1.6 depends on commons-beanutils 1.92 which has a CVE
• Bug #754 guava 29.0 has a CVE
• Bug #752 httpclient 4.5.2 has a CVE
• Bug #750 eventmesh-common pom has junit and assertj has compile dependencies

Document and Code Style Improvement

• Enhancement #806 a complement to code optimization for the eventmesh-examples module
• Enhancement #786 Some suggestions for the eventmesh-sdk-java module
• Enhancement #785 Some suggestions for eventmesh-examples
• Enhancement #784 Some suggestions for the eventmesh-admin module
• Enhancement #783 remove invalid code from the eventmesh-runtime module
• Enhancement #782 invalid code can be removed from the eventmesh-connector-plugin module

Apache EventMesh v1.4.0 (incubating) release

Feature

• Feature #417 A lightable full-featured polyglot capability support

Enhancement

• Enhancement #809 eventmesh trace-zipkin plugin miss the properties
• Enhancement #780 EventListener defines in the level of Consumer may be more proper instead of the level of topic
• Enhancement #774 Remove prodcerGroup and consumerGroup fields in UserAgent, which are strongly related with MQ
• Enhancement #758 Validate the Url parameter in Http Subscriber
• Enhancement #742 missing necessary jar when build deploy package
• Enhancement #735 Update log4j to 2.17.1 (or newer)
• Enhancement #696 improve the metrics/tracing exporters' expandability

Bug

• Bug #768 HTTP Subscriber: Updating subscription information is not taking effect
• Bug #756 upgrade commons-validator as v1.6 depends on commons-beanutils 1.92 which has a CVE
• Bug #754 guava 29.0 has a CVE
• Bug #752 httpclient 4.5.2 has a CVE
• Bug #750 eventmesh-common pom has junit and assertj has compile dependencies

Document and code style improvement

• Enhancement #806 a complement to code optimization for the eventmesh-examples module
• Enhancement #786 Some suggestions for the eventmesh-sdk-java module
• Enhancement #785 Some suggestions for eventmesh-examples
• Enhancement #784 Some suggestions for the eventmesh-admin module
• Enhancement #783 remove invalid code from the eventmesh-runtime module
• Enhancement #782 invalid code can be removed from the eventmesh-connector-plugin module

Apache EventMesh v1.3.0 (incubating) release

Feature

• Feature #339 Integrate With OpenSchema
• Feature #340 Integrate With OpenTelemetry
• Feature #375 In memory as event store
• Feature #482 Support protocol adaptor plugin
• Feature #490 Support service invocation
• Feature #547 Create and upload 1.3.0 version docker image
• Feature #564 Support CloudEvents protocols for pub/sub in EventMesh

Enhancement

• Enhancement #346 How EventMesh offers Administrative API to manage Topic of the eventstore
• Enhancement #367 Enhance SPI plugins
• Enhancement #435 Expose clientmanager/admin APIs as RESTful APIs
• Enhancement #451 SSLContext Initialize error
• Enhancement #460 Support custom retry times configuration when SubcriptionType is SYNC
• Enhancement #523 Adding Flow control RateLimiter support in Http Message Send Processor
• Enhancement #550 Remove unused jar in plugin module
• Enhancement #604 Improve the rebalance algorithm between eventmesh and eventmesh-client

Bug

• Bug #448 EventMeshTCPServer set unknown channel options
• Bug #461 Global flow control is not work in MessageTransferTask
• Bug #476 Biz Exceptions occured in EventMesh cause connection close of client
• Bug #646 Missing the rocketmq message properties during protocol conversion
• Bug #630 RocketMQProducerImpl cannot load config properties from classpath

Document and code style improvement

• Enhancement #405 Looking for code hero for Apache EventMesh
• Enhancement #425 Using templates to encourage useful issues and PRs
• Bug #436 typo errors for runtime package
• Discuss #444 Eventmesh code style specification
• MINOR #653 supply the license and update the third party license file name

Feature

• Feature #339 Integrate With OpenSchema
• Feature #340 Integrate With OpenTelemetry
• Feature #375 In memory as event store
• Feature #482 Support protocol adaptor plugin
• Feature #490 Support service invocation
• Feature #547 Create and upload 1.3.0 version docker image
• Feature #564 Support CloudEvents protocols for pub/sub in EventMesh

Enhancement

• Enhancement #346 How EventMesh offers Administrative API to manage Topic of the eventstore
• Enhancement #367 Enhance SPI plugins
• Enhancement #435 Expose clientmanager/admin APIs as RESTful APIs
• Enhancement #451 SSLContext Initialize error
• Enhancement #460 Support custom retry times configuration when SubcriptionType is SYNC
• Enhancement #523 Adding Flow control RateLimiter support in Http Message Send Processor
• Enhancement #550 Remove unused jar in plugin module
• Enhancement #604 Improve the rebalance algorithm between eventmesh and eventmesh-client

Bug

• Bug #448 EventMeshTCPServer set unknown channel options
• Bug #461 Global flow control is not work in MessageTransferTask
• Bug #476 Biz Exceptions occured in EventMesh cause connection close of client
• Bug #646 Missing the rocketmq message properties during protocol conversion
• Bug #630 RocketMQProducerImpl cannot load config properties from classpath

Document and Code Style Improvement

• Enhancement #405 Looking for code hero for Apache EventMesh
• Enhancement #425 Using templates to encourage useful issues and PRs
• Bug #436 typo errors for runtime package
• Discuss #444 Eventmesh code style specification
• MINOR #653 supply the license and update the third party license file name