Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[ISSUE #199] Kafka connector as event storage plugin #1413

Merged
merged 36 commits into from
Sep 26, 2022
Merged

Conversation

Markliniubility
Copy link
Member

Fixes #199.

Motivation

Support Kafka as event storage

Modifications

Added Kafka-connector-plugin as event storage

Documentation

  • Does this pull request introduce a new feature?
    Yes
  • If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)
    Not yet documented, but will be documented in subsequent PR

@codecov
Copy link

codecov bot commented Sep 25, 2022

Codecov Report

Merging #1413 (e0cdb2c) into master (b560c2a) will increase coverage by 0.03%.
The diff coverage is 0.00%.

@@             Coverage Diff              @@
##             master    #1413      +/-   ##
============================================
+ Coverage     10.42%   10.45%   +0.03%     
- Complexity      764      768       +4     
============================================
  Files           437      437              
  Lines         26585    26588       +3     
  Branches       2929     2929              
============================================
+ Hits           2771     2780       +9     
+ Misses        23555    23548       -7     
- Partials        259      260       +1     
Impacted Files Coverage Δ
.../connector/rocketmq/consumer/PushConsumerImpl.java 24.64% <ø> (ø)
...nector/rocketmq/producer/RocketMQProducerImpl.java 0.00% <0.00%> (ø)
.../protocol/tcp/client/group/ClientGroupWrapper.java 0.00% <0.00%> (ø)
...mesh/connector/standalone/broker/MessageQueue.java 40.25% <0.00%> (+7.79%) ⬆️
...tandalone/broker/task/HistoryMessageClearTask.java 47.05% <0.00%> (+17.64%) ⬆️

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

Copy link
Contributor

@xwm1992 xwm1992 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@xwm1992 xwm1992 merged commit a121196 into master Sep 26, 2022
@xwm1992 xwm1992 deleted the kafka-connector branch November 25, 2022 09:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Support Kafka connector plugin and Kafka as event store
3 participants