[ISSUE #5185] Enhancement for http server and tcp server #5186
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…he#4655) * fix bug for mac get ip address * reformat code style * rename parameter * some enhance * some enhance
… a DecoderException (apache#4702) * [ISSUE apache#4701]fix use tcp protocol client send message, it throw a DecoderException * optmize code * refactor with LengthFieldBasedFrameDecoder * fix code style * optimize code * fix log print * optimize code and add some comments
…Test (apache#4716) * Properly close resources used by WatchFileManagerTest * Create WatchService without try-with-resources The WatchService was being prematurely auto-closed, resulting in ClosedWatchService exceptions * Restructure WatchFileManagerTest.testWatchFile to assert the file change event is detected * Load properties file prior to creating FileWriter in WatchFileManagerTest This change ensures the properties in tempConfigFile are loaded into the properties object before the tempConfigFile is cleared by creating the new FileWriter * Verify onChange is called at least once Depending on when the WatchService begins monitoring for file changes, it is possible that creating the new FileWriter, which clears the provided file, will trigger an onChange call, in addition to the onChange call triggered by properties.store(). * Close WatchService in WatchFileTask.shutdown()
…#4727) * deployment operator, commands simplified. * update * update resources
…se, and elegant logging (apache#4698) * upgrade log4j and slf4j * recommanded example * add known dependencies * remove log4j-to-slf4j * Revert "recommanded example" This reverts commit 9c23c8b. * Deprecate `LogUtils` for removal The `LogUtils` class is not useful because: * it wraps every logger call in `isLevelEnabled`. These are not necessary since the arguments to the logger calls are simple variables and not computationally complex expressions, * currently it breaks location detection of the logger calls, which will always show `LogUtils` as origin, * it prevents the project from using source code rewrite tools like [`rewrite-logging-frameworks`](https://github.com/openrewrite/rewrite-logging-frameworks). This commit adds deprecates the class for removal in the next major version and adds Error Prone's `@InlineMe` annotations, to help users automatically rewrite code based on `LogUtils`. * Add minimal `errorPronePatch` task This task patches the codebase based on Error Prone suggestions (cf. [patching](https://errorprone.info/docs/patching), without adding Error Prone to the main compile task. It is a simplified version of the `gradle-errorprone-plugin` (cf. [installing](https://errorprone.info/docs/installation) and only works on a clean tree using JDK 11. Use as: ./gradlew clean errorPronePatch errorPronePatchTest * Rewrite `LogUtils` call sites This commit contains exclusively code changes performed by Error Prone and rewrites all the callsites to `LogUtils` to use the `Logger` object directly. * add suppliers * Revert "Rewrite `LogUtils` call sites" This reverts commit e78fcef. * Replace the time-consuming method parms with the supplier usage of LogUtil * Execute errorProne scripts and remove blank line by IDEA optimize import * Remove non-supplier methods in LogUtils * Remove unused trace and error log level * Rename LogUtils to LogUtil to save space * Fix checkstyle * Replace isXXXXEnabled to normal use * Rename messageLogger to static final MESSAGE_LOGGER * Fix all checkstyle warnings * run spotlessApply * Fix JDK11 Javadoc task failed * Add {} and fix javadoc task * Revert "Add minimal `errorPronePatch` task" This reverts commit 3e4dc11. * Turn back to surpress javadoc only on JDK8 * Fix logging lack param * Merge branch 'master' into pil0txia_enhance_4697 --------- Co-authored-by: Piotr P. Karwasz <[email protected]>
…pache#4741) * refactor: Use static final modifier to decorate Logger Signed-off-by: Ruslan Mykoliuk <[email protected]> * refactor: Check style Signed-off-by: Ruslan Mykoliuk <[email protected]> * Update EventMeshConstants.java * Update BatchSendMessageProcessor.java * Update EventMeshConstants.java --------- Signed-off-by: Ruslan Mykoliuk <[email protected]>
* Add GRADLE_ENTERPRISE_ACCESS_KEY to a couple of Gradle builds missing it * Update to most recent Gradle Enterprise Gradle Plugin * Move CodeQL verification to its own worfklow * Rename CodeQL workflow to "Analyze" * Rename "Build" workflow to "Docker" * Restore the language matrix with 'java' as the only language in ci workflow * Return the cpp/csharp language step in ci workflow * Rename CodeQL job to "Analyze" rather than "Build"
…pache#4709) * operator quick start link * update * README.zh-CN.md * update README.zh-CN.md * update README.zh-CN.md and add README.md * update README.md * update README.zh-CN.md * update * add deploy operator on k8s * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update * update
…source constraints. (apache#4693) * resources describes the compute resource requirements and limits 、component initialization order rules and DNS. * add license and update runtime resources * update runtime_controller.go * update * deployment operator, commands simplified. * update * update * update * update
apache#4650) * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector. * Implemented the functions of file source connector.
…ling.[EtcdCustomService] (apache#4752) * Enhance thread handling of InterruptedException * inline variable * check code style * catch InterruptedException in a separate catch code block
…pache#4754) * Substitute e.printStackTrace() with log.error() * add exception arg * Modify the wording of the log
…ctor docs (apache#4726) * Update issue template and enable code block rendering * Remove deprecated docs
…ned reply message (apache#4751) * optimized returned reply msg * corrected the change
…uestBody] (apache#4757) * added appropriate getters and setters for HeartbeatEntity class in HeartbeatRequestBody.java. updated EventMeshHttpConsumer.java to access aforementioned variables using correct setters. Updated HeartbeatProcessor.java to access aforementioned variables using correct getters. * <Removed unnecessary getters and setters in eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/HeartbeatRequestBody.java >
… resource [MetaHandler] (apache#4755)
…he#4762) Co-authored-by: orol116 <[email protected]>
…y server (apache#4739) * fix 4738 * fix some bug * fix bug * remove initProducerManager from AbstractRemotingServer init * bug fix * bug fix * some enhance * some enhance * add admin bootstrap * some enhance * remove HttpHandlerManager and ClientManageController. * modify some unit test * add admin http handlermanager
* [ISSUE apache#4458] Support mysql Sink Connector feature * remove pg jdbc import * update dependencies
* resolve conflicts. * resolve
…ache#4777) * Add null check in writeOffset method * delete todo * Move data.put inside null check in writeOffset method * simplify if judgement * remove dev environment * fix style
… when dequeue (apache#4779) * bug fix * bug fix
a. Change to private modifier. b. Repeat code extraction as method.
* condition_check_for_source_eorker * ci_typo_fix * import_order_fix
Bumps commons-io:commons-io from 2.16.1 to 2.17.0. --- updated-dependencies: - dependency-name: commons-io:commons-io dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps `log4jVersion` from 2.23.1 to 2.24.1. Updates `org.apache.logging.log4j:log4j-api` from 2.23.1 to 2.24.1 Updates `org.apache.logging.log4j:log4j-core` from 2.23.1 to 2.24.1 Updates `org.apache.logging.log4j:log4j-slf4j2-impl` from 2.23.1 to 2.24.1 --- updated-dependencies: - dependency-name: org.apache.logging.log4j:log4j-api dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: org.apache.logging.log4j:log4j-core dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: org.apache.logging.log4j:log4j-slf4j2-impl dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…C` task (apache#4743) * checkout submodules * remove possible redundant "check out git submodule" * minor naming unification (inrelevant with PR subject) * Not triggering C task for now * Use the same version of actions/checkout as 'Build' task for 'License Check' task * Revert change to avoid conflict * Update a renamed label
Bumps org.locationtech.jts:jts-core from 1.19.0 to 1.20.0. --- updated-dependencies: - dependency-name: org.locationtech.jts:jts-core dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…nd implementing FunctionRuntime. (apache#5109) * feat: Unified function module * feat: update something * feat: update FunctionRuntime * feat: update FunctionRuntime
… for all Sources(apache#5102)
Bumps software.amazon.awssdk:s3 from 2.28.12 to 2.29.5. --- updated-dependencies: - dependency-name: software.amazon.awssdk:s3 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…pache#5125) Bumps [com.zendesk:mysql-binlog-connector-java](https://github.com/osheroff/mysql-binlog-connector-java) from 0.29.2 to 0.30.1. - [Changelog](https://github.com/osheroff/mysql-binlog-connector-java/blob/master/CHANGELOG.md) - [Commits](https://github.com/osheroff/mysql-binlog-connector-java/commits) --- updated-dependencies: - dependency-name: com.zendesk:mysql-binlog-connector-java dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps [org.redisson:redisson](https://github.com/redisson/redisson) from 3.36.0 to 3.38.1. - [Release notes](https://github.com/redisson/redisson/releases) - [Changelog](https://github.com/redisson/redisson/blob/master/CHANGELOG.md) - [Commits](redisson/redisson@redisson-3.36.0...redisson-3.38.1) --- updated-dependencies: - dependency-name: org.redisson:redisson dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps org.apache.kafka:kafka-clients from 3.7.1 to 3.8.1. --- updated-dependencies: - dependency-name: org.apache.kafka:kafka-clients dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps commons-io:commons-io from 2.17.0 to 2.18.0. --- updated-dependencies: - dependency-name: commons-io:commons-io dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps org.apache.kafka:kafka-clients from 3.8.1 to 3.9.0. --- updated-dependencies: - dependency-name: org.apache.kafka:kafka-clients dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
…#5128) * [ISSUE apache#5127] fix * [ISSUE apache#5127] fix * [ISSUE apache#5127] fix * [ISSUE apache#5127] fix * [ISSUE apache#5127] fix checkstyle test --------- Co-authored-by: JiangShuJu <[email protected]>
* [ISSUE apache#5137] update connector runtime v2 module * fix checkStyle error
* [ISSUE apache#5137] update connector runtime v2 module * fix checkStyle error * [ISSUE apache#5139] update canal connector module
* [ISSUE apache#5137] update connector runtime v2 module * fix checkStyle error * [ISSUE apache#5139] update canal connector module
* [ISSUE apache#5137] update connector runtime v2 module * fix checkStyle error * [ISSUE apache#5139] update canal connector module * [ISSUE apache#5141] update eventmesh-admin-server module
* [ISSUE apache#5137] update connector runtime v2 module * fix checkStyle error * [ISSUE apache#5139] update canal connector module * [ISSUE apache#5141] update eventmesh-admin-server module * [ISSUE apache#5144] update eventmesh-connector-http module
* Update cncf landscape link in README.md * Update README.md
# Conflicts: # .github/workflows/ci.yml # .github/workflows/code-scanning.yml # eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java # eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java # eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java # eventmesh-connectors/eventmesh-connector-jdbc/src/main/resources/source-config.yml # eventmesh-operator/README.md # eventmesh-runtime/scripts/client_manage.sh # eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/MessageUtils.java # eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/common/TCPClient.java # eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/util/RemotingHelperTest.java # eventmesh-sdks/eventmesh-sdk-c/configs/rmb.conf # eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java # settings.gradle
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Fixes #5185
Motivation
Explain the content here.
Explain why you want to make the changes and what problem you're trying to solve.
Modifications
Describe the modifications you've done.
Documentation