add : eventmesh-retry/eventmesh-retry-kafka #5122

HiddenWorld-lk · 2024-10-03T14:40:55Z

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

Does this pull request introduce a new feature? yes
If yes, how is the feature documented? not applicable
If a feature is not applicable for documentation, explain why? because the class and method name is obvious,and the module structure is same as the eventmesh-retry-rocketmq
If a feature is not documented yet in this PR, please create a followup issue for adding the documentation

…ter crashing the runtime and restarting it (apache#4644) * [ISSUE apache#4643]Fix Grpc client can't reconnection when runtime after crashing the runtime and restarting it. * Delete unnecessary code

…itmq (apache#4641) * feat: Add doc for eventmesh-connector-rabbitmq * feat: Add doc for eventmesh-connector-rabbitmq

…eartBeat throw NPE (apache#4653) * [ISSUE apache#4652]Fix EventMeshGrpcConsumer subscribe webhook send heartBeat throw NPE * fix code style * fix runtime code style

…pache#4660) * Add documentation for dingtalk sink connector. * fix

…he#4662) * Add documentation for slack sink connector.

…e#4664)

… invalid request (apache#4666)

…ache#4668) * Unify 'LiteMessage' to 'EventMeshMessage' * Sync connectors doc * Format RabbitMQ & 企业微信 * Format Slack & 钉钉 * Format HTTP & MongoDB * Unify 'EventMesh Runtime' * Unify 'EventMesh' * Fix translation apache#4664 (comment) * Explain additional attributes apache#4591 (comment) * Append: Unify remaining 'EventMesh' * Beautify meshAddress * Add and correct attributes

… package (apache#4669) * [ISSUE apache#4667] Fix some connectors have not been included in the package * fix dependencies check failed * add licenses

…ache#4675) * Switch jdk8 to jre11 * Locate Java executable, check version and apply distinguished vm options https://docs.oracle.com/javase/9/tools/java.htm#GUID-BE93ABDC-999C-4CB5-A88B-1994AAAC74D5__CONVERTGCLOGGINGFLAGSTOXLOG-A5046BD1 * Streamline further * minor: Adjust port seq * minor: Streamline a little * Redirect GC logs to log file instead of stdout * Streamline EVENTMESH_LOG_HOME & XLOG_PARAM * Use multi-stage compiled JRE8 env by default * fix: get pid correctly in docker * Generate pid file exactly under /bin * exec builder_8 exactly after builder_11 * Use JDK instead of JRE * Rename dockerfile

…eadpool (apache#4679) * fix concurrency problem * split task handle threadpool * fix checkstyle problem

apache#4684) * feat: Add doc for eventmesh-connector-redis * feat: Add doc for eventmesh-connector-redis * feat: Add doc for eventmesh-connector-redis * feat: Add doc for eventmesh-connector-redis

* Fix StringDeserializer & (session.timeout.ms)/3 > heartbeat.interval.ms https://stackoverflow.com/questions/38406298/why-cant-i-increase-session-timeout-ms * customize timeout config * add new versions and remove redundant line-breaks * Increase master version * Fix an operator log typo * Revert "Increase master version" This reverts commit c60b559. * Revert 'add new versions for issue template'

…rom deep build insights

* fix tcp client thread not safe * fix bug * fix bug * fix bug * fix bug * fix bug * fix bug * fix style problem * fix style problem * fix style problem

* remove checkstyleMain dependency on spotlessApply spotlessApply was reformatting files on every build causing cache misses. * limit the target of spotlessJava to just src java files * use a TempDir for testing the onChange method, changing file in place caused cache miss * enable gradle build cache

* enhancement for NacosMetaService * fix some bug * fix some style problem

…oard repo

) * [ISSUE apache#4703]Update project version to 1.11.0-SNAPSHOT * update to 1.10.0-release

…4717) * Added test for OpenFunctionSinkConectorTest * Fixed checstyle error * resolved comment for adding @AfterEach()

* fix issue apache#4723 * use constant value

… link promotion (apache#4722)

…ache#4687) * crlf2lf * convert sh only * write easily * Some doc optimization * minor code change * add future win scrpts * add license

…4706) * remove task jar * Supplement 'remove task jar' * http to https

…he#4655) * fix bug for mac get ip address * reformat code style * rename parameter * some enhance * some enhance

Bumps io.vertx:vertx-web-client from 4.5.8 to 4.5.9. --- updated-dependencies: - dependency-name: io.vertx:vertx-web-client dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

Bumps [com.github.fppt:jedis-mock](https://github.com/fppt/jedis-mock) from 1.1.2 to 1.1.3. - [Release notes](https://github.com/fppt/jedis-mock/releases) - [Commits](fppt/jedis-mock@v1.1.2...v1.1.3) --- updated-dependencies: - dependency-name: com.github.fppt:jedis-mock dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

…o 2.7.18 (apache#5056) * Bump org.springframework.boot:spring-boot-starter-jetty Bumps [org.springframework.boot:spring-boot-starter-jetty](https://github.com/spring-projects/spring-boot) from 2.7.10 to 2.7.18. - [Release notes](https://github.com/spring-projects/spring-boot/releases) - [Commits](spring-projects/spring-boot@v2.7.10...v2.7.18) --- updated-dependencies: - dependency-name: org.springframework.boot:spring-boot-starter-jetty dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <[email protected]> * feat: remove duplicate dep --------- Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Pil0tXia <[email protected]>

* Bump gradle/actions from 3 to 4 Bumps [gradle/actions](https://github.com/gradle/actions) from 3 to 4. - [Release notes](https://github.com/gradle/actions/releases) - [Commits](gradle/actions@v3...v4) --- updated-dependencies: - dependency-name: gradle/actions dependency-type: direct:production update-type: version-update:semver-major ... Signed-off-by: dependabot[bot] <[email protected]> * feat: reduce version change --------- Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Pil0tXia <[email protected]>

Bumps `grpcVersion` from 1.65.1 to 1.66.0. Updates `io.grpc:grpc-core` from 1.65.1 to 1.66.0 - [Release notes](https://github.com/grpc/grpc-java/releases) - [Commits](grpc/grpc-java@v1.65.1...v1.66.0) Updates `io.grpc:grpc-protobuf` from 1.65.1 to 1.66.0 - [Release notes](https://github.com/grpc/grpc-java/releases) - [Commits](grpc/grpc-java@v1.65.1...v1.66.0) Updates `io.grpc:grpc-stub` from 1.65.1 to 1.66.0 - [Release notes](https://github.com/grpc/grpc-java/releases) - [Commits](grpc/grpc-java@v1.65.1...v1.66.0) Updates `io.grpc:grpc-netty` from 1.65.1 to 1.66.0 - [Release notes](https://github.com/grpc/grpc-java/releases) - [Commits](grpc/grpc-java@v1.65.1...v1.66.0) Updates `io.grpc:grpc-netty-shaded` from 1.65.1 to 1.66.0 - [Release notes](https://github.com/grpc/grpc-java/releases) - [Commits](grpc/grpc-java@v1.65.1...v1.66.0) Updates `io.grpc:protoc-gen-grpc-java` from 1.65.1 to 1.66.0 - [Release notes](https://github.com/grpc/grpc-java/releases) - [Commits](grpc/grpc-java@v1.65.1...v1.66.0) --- updated-dependencies: - dependency-name: io.grpc:grpc-core dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.grpc:grpc-protobuf dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.grpc:grpc-stub dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.grpc:grpc-netty dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.grpc:grpc-netty-shaded dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.grpc:protoc-gen-grpc-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 software.amazon.awssdk:s3 from 2.26.3 to 2.27.17. --- 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>

Bumps [junit:junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.2. - [Release notes](https://github.com/junit-team/junit4/releases) - [Changelog](https://github.com/junit-team/junit4/blob/main/doc/ReleaseNotes4.12.md) - [Commits](junit-team/junit4@r4.12...r4.13.2) --- updated-dependencies: - dependency-name: junit:junit 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>

…#5095) Bumps com.github.jk1.dependency-license-report from 2.8 to 2.9. --- updated-dependencies: - dependency-name: com.github.jk1.dependency-license-report 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.junit.jupiter:junit-jupiter](https://github.com/junit-team/junit5) from 5.10.3 to 5.11.0. - [Release notes](https://github.com/junit-team/junit5/releases) - [Commits](junit-team/junit5@r5.10.3...r5.11.0) --- updated-dependencies: - dependency-name: org.junit.jupiter:junit-jupiter 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 [com.google.guava:guava](https://github.com/google/guava) from 33.2.1-jre to 33.3.0-jre. - [Release notes](https://github.com/google/guava/releases) - [Commits](https://github.com/google/guava/commits) --- updated-dependencies: - dependency-name: com.google.guava:guava 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>

github-actions

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

Bumps com.gradle.develocity from 3.17.5 to 3.18.1. --- updated-dependencies: - dependency-name: com.gradle.develocity 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 software.amazon.awssdk:s3 from 2.27.17 to 2.28.12. --- 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>

Bumps [com.rabbitmq:amqp-client](https://github.com/rabbitmq/rabbitmq-java-client) from 5.21.0 to 5.22.0. - [Release notes](https://github.com/rabbitmq/rabbitmq-java-client/releases) - [Commits](rabbitmq/rabbitmq-java-client@v5.21.0...v5.22.0) --- updated-dependencies: - dependency-name: com.rabbitmq:amqp-client 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.35.0 to 3.36.0. - [Release notes](https://github.com/redisson/redisson/releases) - [Changelog](https://github.com/redisson/redisson/blob/master/CHANGELOG.md) - [Commits](redisson/redisson@redisson-3.35.0...redisson-3.36.0) --- 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>

…5110) * add unit test for HttpConvertsUtils.java * fix package error * Bump com.gradle.develocity from 3.17.5 to 3.18.1 (apache#5121) Bumps com.gradle.develocity from 3.17.5 to 3.18.1. --- updated-dependencies: - dependency-name: com.gradle.develocity 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> * Bump software.amazon.awssdk:s3 from 2.27.17 to 2.28.12 (apache#5120) Bumps software.amazon.awssdk:s3 from 2.27.17 to 2.28.12. --- 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> * [ISSUE apache#4540] Add unit test for ThreadUtils (apache#5111) * Bump com.rabbitmq:amqp-client from 5.21.0 to 5.22.0 (apache#5119) Bumps [com.rabbitmq:amqp-client](https://github.com/rabbitmq/rabbitmq-java-client) from 5.21.0 to 5.22.0. - [Release notes](https://github.com/rabbitmq/rabbitmq-java-client/releases) - [Commits](rabbitmq/rabbitmq-java-client@v5.21.0...v5.22.0) --- updated-dependencies: - dependency-name: com.rabbitmq:amqp-client 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> * fix CI errors --------- Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Melis Ölmez <[email protected]>

Bumps [org.apache.httpcomponents.client5:httpclient5-fluent](https://github.com/apache/httpcomponents-client) from 5.3.1 to 5.4. - [Changelog](https://github.com/apache/httpcomponents-client/blob/master/RELEASE_NOTES.txt) - [Commits](apache/httpcomponents-client@rel/v5.3.1...rel/v5.4) --- updated-dependencies: - dependency-name: org.apache.httpcomponents.client5:httpclient5-fluent 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#5116) Bumps [org.apache.httpcomponents.client5:httpclient5](https://github.com/apache/httpcomponents-client) from 5.3.1 to 5.4. - [Changelog](https://github.com/apache/httpcomponents-client/blob/master/RELEASE_NOTES.txt) - [Commits](apache/httpcomponents-client@rel/v5.3.1...rel/v5.4) --- updated-dependencies: - dependency-name: org.apache.httpcomponents.client5:httpclient5 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>

qqeasonchen · 2024-11-11T01:36:50Z

@HiddenWorld-lk please make sure the tests are passed.

HiddenWorld-lk · 2024-11-11T02:43:56Z

@HiddenWorld-lk please make sure the tests are passed.

Thanks for your reply!
I have passed the gradle-task-test in my local IDE successfully!

github-actions · 2025-01-24T18:35:16Z

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.

The merge-base changed after approval.

mxsm and others added 30 commits December 14, 2023 15:29

[ISSUE apache#4643]Fix Grpc client can't reconnection when runtime af…

6115009

…ter crashing the runtime and restarting it (apache#4644) * [ISSUE apache#4643]Fix Grpc client can't reconnection when runtime after crashing the runtime and restarting it. * Delete unnecessary code

[ISSUE apache#4607] Documentation Needed for eventmesh-connector-rabb…

b85a58c

…itmq (apache#4641) * feat: Add doc for eventmesh-connector-rabbitmq * feat: Add doc for eventmesh-connector-rabbitmq

feat: Add doc for eventmesh-connector-mongodb (apache#4649)

a77a2fd

[ISSUE apache#4652]Fix EventMeshGrpcConsumer subscribe webhook send h…

f17b82e

…eartBeat throw NPE (apache#4653) * [ISSUE apache#4652]Fix EventMeshGrpcConsumer subscribe webhook send heartBeat throw NPE * fix code style * fix runtime code style

[ISSUE apache#4656] Documentation Needed for eventmesh-connector-http

be8fcc9

[ISSUE apache#4658] Add documentation for dingtalk sink connector. (a…

61e1392

…pache#4660) * Add documentation for dingtalk sink connector. * fix

[ISSUE apache#4661] Add documentation for slack sink connector. (apac…

2fa7017

…he#4662) * Add documentation for slack sink connector.

[issue apache#4663]Add documentation for wecom sink connector. (apach…

8d5b39b

…e#4664)

[ISSUE apache#4659] Fix HTTP source connector stop after receiving an…

d625790

… invalid request (apache#4666)

[ISSUE apache#4667] Fix some connectors have not been included in the…

65fdabf

… package (apache#4669) * [ISSUE apache#4667] Fix some connectors have not been included in the package * fix dependencies check failed * add licenses

[ISSUE apache#4671]Update LICENSE and NOTICE (apache#4672)

03aa825

[ISSUE apache#4630] Fix concurrency problem and split task handle thr…

e056d7a

…eadpool (apache#4679) * fix concurrency problem * split task handle threadpool * fix checkstyle problem

[ISSUE apache#4677]netty codec enhancement (apache#4678)

2989941

[ISSUE apache#4683] Documentation Needed for eventmesh-connector-redis (

1a381ed

apache#4684) * feat: Add doc for eventmesh-connector-redis * feat: Add doc for eventmesh-connector-redis * feat: Add doc for eventmesh-connector-redis * feat: Add doc for eventmesh-connector-redis

[ISSUE apache#4688] Capture build scans on ge.apache.org to benefit f…

bd2aeb9

…rom deep build insights

[ISSUE apache#4695] Fix tcp client not thread safe (apache#4696)

3642be0

* fix tcp client thread not safe * fix bug * fix bug * fix bug * fix bug * fix bug * fix bug * fix style problem * fix style problem * fix style problem

[ISSUE apache#4712]Enhancement for NacosMetaService (apache#4713)

e507497

* enhancement for NacosMetaService * fix some bug * fix some style problem

[ISSUE apache#4714] Migrate eventmesh-admin module to eventmesh-dashb…

dbd96ed

…oard repo

[ISSUE apache#4703]Update project version to 1.10.0-release (apache#4704

196cd11

) * [ISSUE apache#4703]Update project version to 1.11.0-SNAPSHOT * update to 1.10.0-release

[ISSUE apache#4548]Added tests for OpenFunctionSinkConnector (apache#…

b3f5375

…4717) * Added test for OpenFunctionSinkConectorTest * Fixed checstyle error * resolved comment for adding @AfterEach()

[ISSUE apache#4723] Fix get meta from nacos return 403 (apache#4724)

8ebc984

* fix issue apache#4723 * use constant value

[ISSUE apache#4721]Use gradle-build-action for caching and build scan…

c3326c0

… link promotion (apache#4722)

[ISSUE apache#4686] Shell scripts should preserve LF line endings (ap…

a43357c

…ache#4687) * crlf2lf * convert sh only * write easily * Some doc optimization * minor code change * add future win scrpts * add license

[ISSUE apache#4705] Remove redundant Gradle build task 'jar' (apache#…

8eb3d45

…4706) * remove task jar * Supplement 'remove task jar' * http to https

[ISSUE apache#4707]Update rust sdk toolchain (apache#4708)

1ad5fdf

[ISSUE apache#4654]Get Ip address problem when run example code (apac…

a1fce2f

…he#4655) * fix bug for mac get ip address * reformat code style * rename parameter * some enhance * some enhance

dependabot bot and others added 11 commits September 2, 2024 00:30

add : eventmesh-retry/eventmesh-retry-kafka

71658a7

github-actions bot reviewed Oct 3, 2024

View reviewed changes

dependabot bot and others added 10 commits October 5, 2024 01:26

[ISSUE apache#4540] Add unit test for ThreadUtils (apache#5111)

a4e29d8

Merge branch 'master' into retry-kafka

85e27ea

update code style

271b405

qqeasonchen previously approved these changes Nov 25, 2024

View reviewed changes

github-actions bot added the Stale label Jan 24, 2025

xwm1992 force-pushed the master branch from 4ea9f76 to e8fdcd3 Compare February 13, 2025 03:23

github-actions bot removed the Stale label Feb 13, 2025

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

add : eventmesh-retry/eventmesh-retry-kafka #5122

add : eventmesh-retry/eventmesh-retry-kafka #5122

HiddenWorld-lk commented Oct 3, 2024

github-actions bot left a comment

qqeasonchen commented Nov 11, 2024

HiddenWorld-lk commented Nov 11, 2024

github-actions bot commented Jan 24, 2025

add : eventmesh-retry/eventmesh-retry-kafka #5122

Are you sure you want to change the base?

add : eventmesh-retry/eventmesh-retry-kafka #5122

Conversation

HiddenWorld-lk commented Oct 3, 2024

Motivation

Modifications

Documentation

github-actions bot left a comment

Choose a reason for hiding this comment

qqeasonchen commented Nov 11, 2024

HiddenWorld-lk commented Nov 11, 2024

github-actions bot commented Jan 24, 2025