add : eventmesh-retry/eventmesh-retry-kafka #5122
Open
Conversation
This file contains hidden or 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
![github-actions[bot]](https://avatars.githubusercontent.com/in/15368?s=60&v=4){kind=small}
There was a problem hiding this comment.
Welcome to the Apache EventMesh community!!
This is your first PR in our project. We're very excited to have you onboard contributing. Your contributions are greatly appreciated!
Please make sure that the changes are covered by tests.
We will be here shortly.
Let us know if you need any help!
Want to get closer to the community?
| WeChat Assistant | WeChat Public Account | Slack |
|---|---|---|
 |
 |
Join Slack Chat |
Mailing Lists:
| Name | Description | Subscribe | Unsubscribe | Archive |
|---|---|---|---|---|
| Users | User support and questions mailing list | Subscribe | Unsubscribe | Mail Archives |
| Development | Development related discussions | Subscribe | Unsubscribe | Mail Archives |
| Commits | All commits to repositories | Subscribe | Unsubscribe | Mail Archives |
| Issues | Issues or PRs comments and reviews | Subscribe | Unsubscribe | Mail Archives |
|
@HiddenWorld-lk please make sure the tests are passed. |
|
qqeasonchen
previously approved these changes
Nov 25, 2024
|
It has been 60 days since the last activity on this pull request. I am reaching out here to gently remind you that the Apache EventMesh community values every pull request, and please feel free to get in touch with the reviewers at any time. They are available to assist you in advancing the progress of your pull request and offering the latest feedback. If you encounter any challenges during development, seeking support within the community is encouraged. We sincerely appreciate your contributions to Apache EventMesh. |
HiddenWorld-lk
dismissed
qqeasonchen’s stale review
The merge-base changed after approval.
|
It has been 60 days since the last activity on this pull request. I am reaching out here to gently remind you that the Apache EventMesh community values every pull request, and please feel free to get in touch with the reviewers at any time. They are available to assist you in advancing the progress of your pull request and offering the latest feedback. If you encounter any challenges during development, seeking support within the community is encouraged. We sincerely appreciate your contributions to Apache EventMesh. |
|
Hi, would you please resolve conflicts? Then I will help merge this PR. |
|
Sure, I will resolve it in these days ,thank you！
…---Original---
From: ***@***.***>
Date: Sun, Jul 27, 2025 10:47 AM
To: ***@***.***>;
Cc: ***@***.******@***.***>;
Subject: Re: [apache/eventmesh] add : eventmesh-retry/eventmesh-retry-kafka(PR #5122)
Pil0tXia left a comment (apache/eventmesh#5122)
Hi, would you please resolve conflicts? Then I will help merge this PR.
—
Reply to this email directly, view it on GitHub, or unsubscribe.
You are receiving this because you were mentioned.Message ID: ***@***.***>
|
# Conflicts: # build.gradle # eventmesh-common/build.gradle # eventmesh-common/gradle.properties # eventmesh-emesher/build.gradle # eventmesh-sdk-java/build.gradle # settings.gradle
# Conflicts: # README.md # README.zh-CN.md # docs/README.md # docs/cn/README.md # docs/cn/features/https.zh-CN.md # docs/cn/instructions/eventmesh-runtime-quickstart.zh-CN.md # docs/cn/instructions/eventmesh-sdk-java-quickstart.zh-CN.md # docs/cn/instructions/quickstart.zh-CN.md # docs/en/README.md # docs/en/features/https.md # docs/en/instructions/eventmesh-runtime-quickstart.md # docs/en/instructions/quickstart.md # eventmesh-emesher/src/main/java/cn/webank/emesher/admin/controller/ClientManageController.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/AbrstractHTTPServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/AbstractRemotingServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyHTTPServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyStartup.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyTCPServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/common/Pair.java # eventmesh-emesher/src/main/java/cn/webank/emesher/common/ServiceState.java # eventmesh-emesher/src/main/java/cn/webank/emesher/configuration/AccessConfiguration.java # eventmesh-emesher/src/main/java/cn/webank/emesher/configuration/CommonConfiguration.java # eventmesh-emesher/src/main/java/cn/webank/emesher/configuration/ConfigurationWraper.java # eventmesh-emesher/src/main/java/cn/webank/emesher/configuration/ProxyConfiguration.java # eventmesh-emesher/src/main/java/cn/webank/emesher/constants/ProxyConstants.java # eventmesh-emesher/src/main/java/cn/webank/emesher/constants/ProxyVersion.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/consumergroup/ConsumerGroupConf.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/consumergroup/ConsumerGroupTopicConf.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/consumergroup/ProducerGroupConf.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/consumergroup/event/ConsumerGroupInstanceChangeEvent.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/consumergroup/event/ConsumerGroupStateEvent.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/consumergroup/event/ConsumerGroupTopicConfChangeEvent.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/async/AsyncContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/async/CompleteHandler.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/consumer/ConsumerGroupManager.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/consumer/ConsumerManager.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/consumer/HandleMsgContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/AdminMetricsProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/AdminShutdownProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/BatchSendMessageProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/BatchSendMessageV2Processor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/ReplyMessageProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/SendAsyncMessageProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/SendSyncMessageProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/SubscribeProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/UnSubscribeProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/processor/inf/HttpRequestProcessor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/producer/ProducerManager.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/producer/ProxyProducer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/producer/SendMessageContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/push/AbstractHTTPPushRequest.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/push/AsyncHTTPPushRequest.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/push/HTTPClientPool.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/push/HTTPMessageHandler.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/push/MessageHandler.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/retry/DelayRetryable.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/retry/HttpRetryer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/http/retry/RetryContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/ProxyTcp2Client.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/ProxyTcpConnectionHandler.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/ProxyTcpExceptionHandler.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/ProxyTcpMessageDispatcher.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/group/ClientGroupWrapper.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/group/ClientSessionGroupMapping.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/group/dispatch/DownstreamDispatchStrategy.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/group/dispatch/FreePriorityDispatchStrategy.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/Session.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/SessionContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/SessionState.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/ClientAckContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/DownStreamMsgContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/PushContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/SessionPusher.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/retry/ProxyTcpRetryer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/send/ProxyTcpSendResult.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/send/ProxyTcpSendStatus.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/send/SessionSender.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/send/UpStreamMsgContext.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/AbstractTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/GoodbyeTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/HeartBeatTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/HelloTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/ListenTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/MessageAckTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/MessageTransferTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/SubscribeTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/UnSubscribeTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/MonitorMetricConstants.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/http/GroupMetrics.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/http/HTTPMetricsServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/http/HealthMetrics.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/http/SummaryMetrics.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/http/TcpSummaryMetrics.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/http/TopicMetrics.java # eventmesh-emesher/src/main/java/cn/webank/emesher/metrics/tcp/ProxyTcpMonitor.java # eventmesh-emesher/src/main/java/cn/webank/emesher/threads/ProxyThreadFactoryImpl.java # eventmesh-emesher/src/main/java/cn/webank/emesher/util/ProxyUtil.java # eventmesh-emesher/src/main/java/cn/webank/emesher/util/ServerGlobal.java # eventmesh-emesher/src/main/java/cn/webank/emesher/util/Utils.java # eventmesh-emesher/src/main/java/cn/webank/emesher/util/ValueComparator.java # eventmesh-emesher/src/main/java/com/webank/emesher/admin/controller/ClientManageController.java # eventmesh-emesher/src/main/java/com/webank/emesher/boot/AbrstractHTTPServer.java # eventmesh-emesher/src/main/java/com/webank/emesher/boot/AbstractRemotingServer.java # eventmesh-emesher/src/main/java/com/webank/emesher/boot/ProxyHTTPServer.java # eventmesh-emesher/src/main/java/com/webank/emesher/boot/ProxyServer.java # eventmesh-emesher/src/main/java/com/webank/emesher/boot/ProxyStartup.java # eventmesh-emesher/src/main/java/com/webank/emesher/boot/ProxyTCPServer.java # eventmesh-emesher/src/main/java/com/webank/emesher/common/Pair.java # eventmesh-emesher/src/main/java/com/webank/emesher/common/ServiceState.java # eventmesh-emesher/src/main/java/com/webank/emesher/configuration/AccessConfiguration.java # eventmesh-emesher/src/main/java/com/webank/emesher/configuration/CommonConfiguration.java # eventmesh-emesher/src/main/java/com/webank/emesher/configuration/ConfigurationWraper.java # eventmesh-emesher/src/main/java/com/webank/emesher/configuration/ProxyConfiguration.java # eventmesh-emesher/src/main/java/com/webank/emesher/constants/ProxyConstants.java # eventmesh-emesher/src/main/java/com/webank/emesher/constants/ProxyVersion.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/consumergroup/ConsumerGroupConf.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/consumergroup/ConsumerGroupTopicConf.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/consumergroup/ProducerGroupConf.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/consumergroup/event/ConsumerGroupInstanceChangeEvent.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/consumergroup/event/ConsumerGroupStateEvent.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/consumergroup/event/ConsumerGroupTopicConfChangeEvent.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/async/AsyncContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/async/CompleteHandler.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/consumer/ConsumerGroupManager.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/consumer/ConsumerManager.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/consumer/HandleMsgContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/AdminMetricsProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/AdminShutdownProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/BatchSendMessageProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/BatchSendMessageV2Processor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/ReplyMessageProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/SendAsyncMessageProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/SendSyncMessageProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/SubscribeProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/UnSubscribeProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/processor/inf/HttpRequestProcessor.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/producer/ProducerManager.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/producer/ProxyProducer.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/producer/SendMessageContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/push/AbstractHTTPPushRequest.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/push/AsyncHTTPPushRequest.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/push/HTTPClientPool.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/push/HTTPMessageHandler.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/push/MessageHandler.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/retry/DelayRetryable.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/retry/HttpRetryer.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/http/retry/RetryContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/ProxyTcp2Client.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/ProxyTcpConnectionHandler.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/ProxyTcpExceptionHandler.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/ProxyTcpMessageDispatcher.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/group/ClientGroupWrapper.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/group/ClientSessionGroupMapping.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/group/dispatch/DownstreamDispatchStrategy.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/group/dispatch/FreePriorityDispatchStrategy.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/Session.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/SessionContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/SessionState.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/push/ClientAckContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/push/DownStreamMsgContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/push/PushContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/push/SessionPusher.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/push/retry/ProxyTcpRetryer.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/send/ProxyTcpSendResult.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/send/ProxyTcpSendStatus.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/send/SessionSender.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/session/send/UpStreamMsgContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/AbstractTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/GoodbyeTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/HeartBeatTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/HelloTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/ListenTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/MessageAckTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/MessageTransferTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/SubscribeTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/core/protocol/tcp/client/task/UnSubscribeTask.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/MonitorMetricConstants.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/http/GroupMetrics.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/http/HTTPMetricsServer.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/http/HealthMetrics.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/http/SummaryMetrics.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/http/TcpSummaryMetrics.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/http/TopicMetrics.java # eventmesh-emesher/src/main/java/com/webank/emesher/metrics/tcp/ProxyTcpMonitor.java # eventmesh-emesher/src/main/java/com/webank/emesher/patch/ProxyConsumeConcurrentlyContext.java # eventmesh-emesher/src/main/java/com/webank/emesher/patch/ProxyConsumeConcurrentlyStatus.java # eventmesh-emesher/src/main/java/com/webank/emesher/patch/ProxyMessageListenerConcurrently.java # eventmesh-emesher/src/main/java/com/webank/emesher/util/ProxyThreadFactoryImpl.java # eventmesh-emesher/src/main/java/com/webank/emesher/util/ProxyUtil.java # eventmesh-emesher/src/main/java/com/webank/emesher/util/ServerGlobal.java # eventmesh-emesher/src/main/java/com/webank/emesher/util/Utils.java # eventmesh-emesher/src/main/java/com/webank/emesher/util/ValueComparator.java # eventmesh-registry/build.gradle # eventmesh-runtime/bin/start.sh # eventmesh-runtime/bin/stop.sh # eventmesh-runtime/bin/watchdog.sh # eventmesh-runtime/build.gradle # eventmesh-runtime/conf/log-client.properties # eventmesh-runtime/conf/log4j2.xml # eventmesh-runtime/conf/proxy.properties # eventmesh-runtime/conf/server.env # eventmesh-runtime/gradle.properties # eventmesh-runtime/scripts/before_shutdown.sh # eventmesh-runtime/scripts/client_manage.sh # eventmesh-runtime/scripts/connections.sh # eventmesh-runtime/scripts/histo.sh # eventmesh-runtime/scripts/histo_suspects.sh # eventmesh-runtime/scripts/jstack.sh # eventmesh-runtime/scripts/monitor_connections.sh # eventmesh-runtime/scripts/monitor_histo_suspects.sh # eventmesh-runtime/scripts/monitor_threads.sh # eventmesh-runtime/scripts/session.sh # eventmesh-runtime/scripts/threads.sh # eventmesh-runtime/src/main/java/com/webank/runtime/admin/controller/ClientManageController.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/AbrstractHTTPServer.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/AbstractRemotingServer.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/ProxyHTTPServer.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/ProxyServer.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/ProxyStartup.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/ProxyTCPServer.java # eventmesh-runtime/src/main/java/com/webank/runtime/boot/SSLContextFactory.java # eventmesh-runtime/src/main/java/com/webank/runtime/common/Pair.java # eventmesh-runtime/src/main/java/com/webank/runtime/common/ServiceState.java # eventmesh-runtime/src/main/java/com/webank/runtime/configuration/AccessConfiguration.java # eventmesh-runtime/src/main/java/com/webank/runtime/configuration/CommonConfiguration.java # eventmesh-runtime/src/main/java/com/webank/runtime/configuration/ConfigurationWraper.java # eventmesh-runtime/src/main/java/com/webank/runtime/configuration/ProxyConfiguration.java # eventmesh-runtime/src/main/java/com/webank/runtime/constants/ProxyConstants.java # eventmesh-runtime/src/main/java/com/webank/runtime/constants/ProxyVersion.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/consumergroup/ConsumerGroupConf.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/consumergroup/ConsumerGroupTopicConf.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/consumergroup/ProducerGroupConf.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/consumergroup/event/ConsumerGroupInstanceChangeEvent.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/consumergroup/event/ConsumerGroupStateEvent.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/consumergroup/event/ConsumerGroupTopicConfChangeEvent.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/MQConsumerWrapper.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/MQProducerWrapper.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/MQWrapper.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/DeFiBusConsumerImpl.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/DeFiBusProducerImpl.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/MeshMQConsumer.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/MeshMQProducer.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/RocketMQConsumerImpl.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/RocketMQProducerImpl.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/async/AsyncContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/async/CompleteHandler.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/consumer/ConsumerGroupManager.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/consumer/ConsumerManager.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/consumer/HandleMsgContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/consumer/ProxyConsumer.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/AdminMetricsProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/AdminShutdownProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/ReplyMessageProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/SendSyncMessageProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/SubscribeProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/UnSubscribeProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/processor/inf/HttpRequestProcessor.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/producer/ProducerManager.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/producer/ProxyProducer.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/producer/SendMessageContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/push/AbstractHTTPPushRequest.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/push/HTTPClientPool.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/push/HTTPMessageHandler.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/push/MessageHandler.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/retry/DelayRetryable.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/retry/HttpRetryer.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/http/retry/RetryContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/ProxyTcp2Client.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/ProxyTcpConnectionHandler.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/ProxyTcpExceptionHandler.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/ProxyTcpMessageDispatcher.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/group/ClientSessionGroupMapping.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/group/dispatch/DownstreamDispatchStrategy.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/group/dispatch/FreePriorityDispatchStrategy.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/Session.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/SessionContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/SessionState.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/push/PushContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/push/SessionPusher.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/push/retry/ProxyTcpRetryer.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/send/ProxyTcpSendResult.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/send/ProxyTcpSendStatus.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/send/SessionSender.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/send/UpStreamMsgContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/AbstractTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/GoodbyeTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/HeartBeatTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/HelloTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/ListenTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/MessageAckTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/MessageTransferTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/SubscribeTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/UnSubscribeTask.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/MonitorMetricConstants.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/http/GroupMetrics.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/http/HTTPMetricsServer.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/http/HealthMetrics.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/http/SummaryMetrics.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/http/TcpSummaryMetrics.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/http/TopicMetrics.java # eventmesh-runtime/src/main/java/com/webank/runtime/metrics/tcp/ProxyTcpMonitor.java # eventmesh-runtime/src/main/java/com/webank/runtime/patch/ProxyConsumeConcurrentlyContext.java # eventmesh-runtime/src/main/java/com/webank/runtime/patch/ProxyConsumeConcurrentlyStatus.java # eventmesh-runtime/src/main/java/com/webank/runtime/patch/ProxyMessageListenerConcurrently.java # eventmesh-runtime/src/main/java/com/webank/runtime/util/ProxyThreadFactoryImpl.java # eventmesh-runtime/src/main/java/com/webank/runtime/util/ProxyUtil.java # eventmesh-runtime/src/main/java/com/webank/runtime/util/ServerGlobal.java # eventmesh-runtime/src/main/java/com/webank/runtime/util/Utils.java # eventmesh-runtime/src/main/java/com/webank/runtime/util/ValueComparator.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyContext.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/ProxyConsumeConcurrentlyStatus.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/ProxyMessageListenerConcurrentlyOnce.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java # eventmesh-runtime/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java # eventmesh-runtime/src/test/java/client/common/Codec.java # eventmesh-runtime/src/test/java/client/common/Server.java # eventmesh-runtime/src/test/java/client/common/UserAgentUtils.java # eventmesh-runtime/src/test/resources/log4j2.xml # eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/patch/EventMeshMessageListenerConcurrently.java # settings.gradle
…running in docker
…running in docker
# Conflicts: # docs/cn/instructions/eventmesh-runtime-protocol.zh-CN.md # docs/en/instructions/eventmesh-runtime-protocol.md # eventmesh-common/src/main/java/cn/webank/eventmesh/common/protocol/tcp/AccessMessage.java # eventmesh-common/src/main/java/cn/webank/eventmesh/common/protocol/tcp/EventMeshMessage.java # eventmesh-common/src/main/java/cn/webank/eventmesh/common/protocol/tcp/codec/Codec.java # eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/tcp/AccessMessage.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyStartup.java # eventmesh-emesher/src/main/java/cn/webank/emesher/boot/ProxyTCPServer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/configuration/AccessConfiguration.java # eventmesh-emesher/src/main/java/cn/webank/emesher/configuration/EventMeshConfiguration.java # eventmesh-emesher/src/main/java/cn/webank/emesher/constants/ProxyConstants.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/ProxyTcpMessageDispatcher.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/Session.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/SessionPusher.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/push/retry/ProxyTcpRetryer.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/session/send/SessionSender.java # eventmesh-emesher/src/main/java/cn/webank/emesher/core/protocol/tcp/client/task/MessageTransferTask.java # eventmesh-emesher/src/main/java/cn/webank/emesher/util/ProxyUtil.java # eventmesh-emesher/src/main/java/cn/webank/emesher/util/Utils.java # eventmesh-runtime/src/main/java/com/webank/eventmesh/runtime/configuration/AccessConfiguration.java # eventmesh-runtime/src/main/java/com/webank/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java # eventmesh-runtime/src/test/java/client/common/Codec.java # eventmesh-runtime/src/test/java/client/common/MessageUtils.java # eventmesh-runtime/src/test/java/demo/AsyncSubClient.java # eventmesh-runtime/src/test/java/demo/BroadCastSubClient.java # eventmesh-runtime/src/test/java/demo/SyncPubClient.java # eventmesh-runtime/src/test/java/test/BasicTest.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/RemotingServer.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/EventMeshClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/WemqAccessClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/EventMeshCommon.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/EventMeshThreadFactoryImpl.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/WemqAccessCommon.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/WemqAccessThreadFactoryImpl.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/DefaultEventMeshClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/DefaultWemqAccessClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/SimplePubClientImpl.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/SimpleSubClientImpl.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/consumer/LiteConsumer.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/WemqAccessClient.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/WemqAccessCommon.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/WemqAccessThreadFactoryImpl.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/impl/DefaultWemqAccessClient.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/common/AccessTestUtils.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/common/EventMeshTestCaseTopicSet.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/common/EventMeshTestUtils.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/demo/AsyncPublishBroadcast.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/demo/AsyncSubscribe.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/demo/AsyncSubscribeBroadcast.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/demo/SyncRequest.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/demo/SyncResponse.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/http/demo/AsyncPublishInstance.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/http/demo/AsyncSyncRequestInstance.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/http/demo/SyncRequestInstance.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/tcp/common/AccessTestUtils.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/tcp/demo/AsyncPublish.java # eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/sub/service/SubService.java
# Conflicts: # eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/client/hook/ReceiveMsgHook.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/RemotingServer.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/conf/LiteClientConfig.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/consumer/HandleResult.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/consumer/listener/LiteMessageListener.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/http/HttpUtil.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/http/RequestParam.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/producer/LiteProducer.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/producer/RRCallback.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/http/producer/RRCallbackResponseHandlerAdapter.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/SimplePubClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/SimpleSubClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/WemqAccessClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/MessageUtils.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/RequestContext.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/TcpClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/WemqAccessCommon.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/common/WemqAccessThreadFactoryImpl.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/DefaultWemqAccessClient.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/SimplePubClientImpl.java # eventmesh-sdk-java/src/main/java/cn/webank/eventmesh/client/tcp/impl/SimpleSubClientImpl.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/EventMeshRetObj.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/RemotingServer.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/conf/LiteClientConfig.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/consumer/HandleResult.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/consumer/listener/LiteMessageListener.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/http/HttpUtil.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/http/RequestParam.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/producer/LiteProducer.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/producer/RRCallback.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/http/producer/RRCallbackResponseHandlerAdapter.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/EventMeshClient.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/SimplePubClient.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/SimpleSubClient.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/AsyncRRCallback.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/EventMeshCommon.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/EventMeshThreadFactoryImpl.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/MessageUtils.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/ReceiveMsgHook.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/RequestContext.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/common/TcpClient.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/impl/DefaultEventMeshClient.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/impl/SimplePubClientImpl.java # eventmesh-sdk-java/src/main/java/com/webank/eventmesh/client/tcp/impl/SimpleSubClientImpl.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractLiteClient.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/EventMeshRetObj.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/RemotingServer.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/conf/LiteClientConfig.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/HandleResult.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/LiteConsumer.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/context/LiteConsumeContext.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/listener/LiteMessageListener.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/http/HttpUtil.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/http/RequestParam.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/LiteProducer.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/RRCallback.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/RRCallbackResponseHandlerAdapter.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/ssl/MyX509TrustManager.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/EventMeshClient.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/SimplePubClient.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/SimpleSubClient.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/AsyncRRCallback.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/EventMeshCommon.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/EventMeshThreadFactoryImpl.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/ReceiveMsgHook.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/RequestContext.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/DefaultEventMeshClient.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/SimplePubClientImpl.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/SimpleSubClientImpl.java # eventmesh-sdk-java/src/main/resources/log4j2.xml # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/common/AccessTestUtils.java # eventmesh-sdk-java/src/test/java/cn/webank/eventmesh/client/tcp/demo/SyncResponse.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/tcp/common/EventMeshTestUtils.java # eventmesh-sdk-java/src/test/java/com/webank/eventmesh/client/tcp/demo/SyncResponse.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/AsyncPublishInstance.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/AsyncSyncRequestInstance.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/SyncRequestInstance.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestCaseTopicSet.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/common/EventMeshTestUtils.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncPublish.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncPublishBroadcast.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncSubscribe.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncSubscribeBroadcast.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/SyncRequest.java # eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/SyncResponse.java # eventmesh-sdk-java/src/test/resources/log4j2.xml # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/EventMeshRetObj.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/AsyncRRCallback.java
* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository * update build.gradle * update build.gradle and gradle.properties * update build.gradle and gradle.properties for publish to maven repository * * update gradle version for instructions * fix: dist task exception * [ISSUE apache#329]Missing Log4j dependency * update eventmesh-runtime.png * update eventmesh-panels.png
* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository * update build.gradle * update build.gradle and gradle.properties * update build.gradle and gradle.properties for publish to maven repository * * update gradle version for instructions * fix: dist task exception * [ISSUE apache#329]Missing Log4j dependency * update eventmesh-runtime.png * update eventmesh-panels.png
* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository * update build.gradle * update build.gradle and gradle.properties * update build.gradle and gradle.properties for publish to maven repository * * update gradle version for instructions * fix: dist task exception * [ISSUE apache#329]Missing Log4j dependency * update eventmesh-runtime.png * update eventmesh-panels.png
…e normalization: remove external system dependencies.
* Update TcpClient.java Save and re-use this "Random" * Update TcpClient.java * Update TcpClient.java --------- Co-authored-by: mike_xwm <[email protected]>
* move go-sdks to eventmesh-sdks module * [ISSUE apache#4001] Add eventmesh-sdks module # Conflicts: # README.md # eventmesh-connectors/README.md # eventmesh-connectors/eventmesh-connector-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/config/OpenaiProxyConfig.java # eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/common/SourceInfo.java # eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/build.gradle # eventmesh-retry/eventmesh-retry-api/build.gradle # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/AsyncRRCallback.java # eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/conf/EventMeshTCPClientConfig.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshMessageProducer.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/AsyncRRCallback.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/conf/EventMeshTCPClientConfig.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPClient.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPClient.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPPubClient.java # eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPSubClient.java # eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducerTest.java # eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtilTest.java # eventmesh-sdks/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/impl/EventMeshTCPClientFactoryTest.java # eventmesh-sdks/eventmesh-sdk-rust/.gitignore # eventmesh-sdks/eventmesh-sdk-rust/Cargo.lock # eventmesh-sdks/eventmesh-sdk-rust/Cargo.toml # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/Cargo.toml # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/build.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/proto/eventmesh-client.proto # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/constants.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/config.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/consumer.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/mod.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/grpc/producer.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/config.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/mod.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/producer.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/protocol_key.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/http/request_code.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/lib.rs # eventmesh-sdks/eventmesh-sdk-rust/eventmesh/src/message.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/Cargo.lock # eventmesh-sdks/eventmesh-sdk-rust/examples/Cargo.toml # eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-consumer-stream.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-consumer.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-producer-batch-publish.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-producer-publish.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/grpc-producer-request.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/http-producer-publish.rs # eventmesh-sdks/eventmesh-sdk-rust/examples/http-producer-request.rs # settings.gradle # tools/dependency-check/known-dependencies.txt
* Fix JUnit dependecy issue in eventmesh-storage-kafka * Clean up JUnit dependency in eventmesh-protocol-grpc * Remove empty arguments to @test annotations Adding empty arguments adds no value, and will just interfere with future efforts to migrate to JUnit Jupiter. * Remove PowerMockito usages PowerMockito is known to be slow and cumbersome compared to Mockito. In most cases, removing it was a straight forward change of removing the PowerMockito annotations and use the MockitoJUnitRunner. In the single non-trivial case, WebHookProcessorTest, PowerMockito's WhiteBox was removed and replaced with Mockito's @Injectmocks annotation. * Clean up Mockito dependencies mockito-inline is intended to replace mockito-core in cerain situations (e.g., mocking static or final classes), and there's no need to have them both as dependencies in the same module. This patch cleans up these duplications and leaves a "slimmer" dependency tree with just the required mockito dependency in each module. * Remove unneeded "org.apache.rocketmq:rocketmq-test dependency * Migrate testing to JUnit Jupiter In its current form, the project has some JUnit 4 and some JUnit 5 (Jupiter) tests. This patch aims to align all the tests to a single modern framework, JUnit Jupiter, in order to make future development easier. As this patch is already pretty large as-is, it attempts to be non-opinionated and simply replace JUnit 4 calls with the closed JUnit Jupiter equivalents. Subsequent work may want to change some tests to take further advantage of JUnit Jupiter's features. This patch includes the following changes: 1. Gradle dependencies: a. All the dependencies under org.junit.jupiter were consolidated to use the single artifact org.junit.jupiter:junit-jupiter. b. The junit:junit dependency was removed in favor of org.junit.jupiter:junit-jupiter as mentioned in 1.a.. c. The org.mockito:mockito-junit-jupiter dependency was added to provide the integration with Mockito. d. The com.github.stefanbirkner:system-rules dependency was removed in favor of org.junit-pioneer:junit-pioneer that was used to provide the same functionality as mentioned in 2.i. 2. Annotations a. org.junit.jupiter.api.BeforeEach was used as a drop-in replacement for org.junit.Before. b. org.junit.jupiter.api.BeforeAll was used as a drop-in replacement for org.junit.BeforeClass. c. org.junit.jupiter.api.AfterEach was used as a drop-in replacement for org.junit.After. d. org.junit.jupiter.api.AfterAll was used as a drop-in replacement for org.junit.AfterClass. e. org.junit.jupiter.api.AfterEach was used as a drop-in replacement for org.junit.After. f. org.junit.jupiter.api.Disabled was used as a drop-in replacement for org.junit.Ignore. g. org.junit.jupiter.api.Test was used as a replacement for org.junit.Test, although with some caveats: 1. For the simple case with no arguments, org.junit.jupiter.api.Test was used as a drop-in replacement for org.junit.Test. 2. For the case where org.junit.Test was used with a timeout argument, a combination of org.junit.jupiter.api.Test and org.junit.jupiter.api.Timeout was used. 3. For the case where org.junit.Test was used with an expected argument, org.junit.jupiter.api.Test was used, but the assertion on the exception begin thrown is done explicitly in the test's code, see 3.e. below. h. org.junit.jupiter.api.extension.ExtendWith was used as a replacement for org.junit.runner.RunWith with an extension corresponding to the runner being replaced. a. org.mockito.junit.jupiter.MockitoExtension was used to provide the same functionality as org.mockito.junit.MockitoJUnitRunner. Since the extension is stricter than the runner, in some cases org.mockito.junit.jupiter.MockitoSettings was used to explicitly make the mocking more lenient. i. org.junitpioneer.jupiter.SetEnvironmentVariable was used in order to set environment variables in the tests instead of explicitly calling org.junit.contrib.java.lang.system.EnvironmentVariables in the test's body. As an added bonus, using this annotation also cleans up the changes to the environment variables when the test is over and prevents it from inadvertently effecting other tests. 3. Assertions a. org.junit.jupiter.api.Assertions was used as a drop-in replacement for org.junit.Assert for the case where the assertion was performed without a message. b. org.junit.jupiter.api.Assertions was used instead of org.junit.Assert in the cases where an assertion method was used with a message, but the argument were permuted to fit the new method's signature. c. org.junit.jupiter.api.Assertions does not have an equivalent of org.junit.Assert's assertThat method, but luckily it was only used in a few places, and always used the org.hamcrest.CoreMatchers.is matcher. These assertions were rewritten as straight-forward assertEquals assertions. c. org.junit.jupiter.api.Assertions does not have an equivalent of org.junit.Assert's assertThat method, but luckily it was only used in a few places, and always used the org.hamcrest.CoreMatchers.is matcher. These assertions were rewritten as straight-forward assertEquals assertions. d. org.junit.jupiter.api.Assertions does not have an equivalent of org.hamcrest.MatcherAssert's assertThat method, but luckily it was only used in a few places, and always used the org.hamcrest.CoreMatchers.is matcher. These assertions were rewritten as straight-forward assertEquals assertions. e. org.junit.jupiter.api.Assertions' assertThrows was used to assert an expected exception is throws instead of using org.junit.Test with the expected annotation. * Fix dependency check
HiddenWorld-lk
force-pushed
the
retry-kafka
branch
from
271b405 to
409b9e4
Compare
|
I have resolved the conflicts. |
|
It has been 60 days since the last activity on this pull request. I am reaching out here to gently remind you that the Apache EventMesh community values every pull request, and please feel free to get in touch with the reviewers at any time. They are available to assist you in advancing the progress of your pull request and offering the latest feedback. If you encounter any challenges during development, seeking support within the community is encouraged. We sincerely appreciate your contributions to Apache EventMesh. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
11 participants
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.
Motivation
I just want to add the retry module of Kafka named eventmesh-retry-kafka.
Modifications
Add a new module named eventmesh-retry-kafka in eventmesh-retry .
Documentation