Releases: apache/eventmesh
Releases · apache/eventmesh
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 Docu...
Apache EventMesh v1.9.0
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
Apache EventMesh v1.8.0 (Incubating)
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
Apache EventMesh v1.7.0 (Incubating)
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)
Apache EventMesh v1.6.0 (Incubating)
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)
Apache EventMesh v1.5.0 (Incubating)
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-javaandeventmesh-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
Producerinterface - 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
Apache EventMesh v1.4.0 (Incubating)
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)
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
Apache EventMesh v1.2.0 (Incubating)
Feature
- ISSUE #74 Suggest support rocketmq as store
- ISSUE #176 Support Spi for extended implementation to accommodate a variety of MQ
- ISSUE #190 Support pub/sub ,heartbeat manage and subscribe manage for http
- ISSUE #201 Support running eventmesh in docker
Improvement
- ISSUE #391 Optimize interface design in eventmesh-connector-api
- ISSUE #378 downstream broadcast msg asynchronously
- ISSUE #186 Separate the eventmesh-connector-defibus and eventmesh-connector-rocketmq config from eventmesh-runtime
- ISSUE #366 Clear some legacy concept
- ISSUE #256 Upgrade Openmessaging-api to 2.2.1-pubsub version
Bug
- ISSUE #397 Remove subscription session failed error
- ISSUE #386 ConsumerGroup Queue Offset is not synced up correctly after PullConsumer has consumer all the messages in the topic
- ISSUE #382 java.lang.NumberFormatException when parsing Long
- ISSUE #368 Racing Condition problem in EventMesh SDK's LiteConsumer HTTP Client
- ISSUE #211 Rocketmq-connector throw nullpointer exception
- ISSUE #203 The consumer pull request message's attribute 'bizSeqNo' is null
- ISSUE #212 For multiple listening instances, only the last started instance can receive messages
- ISSUE #216 EventMesh ProxyTcpRetryer throws NumberFormatException
- ISSUE #226 eventMesh-rocketmq-connector tcp pub throw operation time out exception
- ISSUE #188 Test send sync RR(request-response) msg failed, just send one message, but receive msgs continuously
- ISSUE #184 Eventmesh-connector-rocketmq can not send and receive msg successfully
- ISSUE #220 pub/sub client fails to start
- ISSUE #222 When onChange is NEW, eventMesh occurred NullPointException
Document and Code Style Improvement
- ISSUE #393 The topic name in test file is long and obscure
- ISSUE #302 Add "Incubating" to the project name in docs
- ISSUE #306 Modify the package name to org.apache and improve the test cases
- ISSUE #304 Lack Notice file of eventmesh project
- ISSUE #295 Lack of licenses in each source file under the eventmesh-runtime module
- ISSUE #265 Specification of code structure and file naming
- ISSUE #219 Supply detail information or read.me for eventmesh running in docker
- ISSUE #242 Lack protocol document in English
