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

Support Kafka connector plugin and Kafka as event store #199

Closed
xwm1992 opened this issue Jan 20, 2021 · 10 comments · Fixed by #1413
Closed

Support Kafka connector plugin and Kafka as event store #199

xwm1992 opened this issue Jan 20, 2021 · 10 comments · Fixed by #1413
Assignees
Labels
discussion This issue requires further discussion enhancement New feature or request kind

Comments

@xwm1992
Copy link
Contributor

xwm1992 commented Jan 20, 2021

Support Kafka connector to deliver event to Kafka, and please help me how can i implement this feature.

@xwm1992 xwm1992 added enhancement New feature or request kind labels Jan 21, 2021
@MajorHe1 MajorHe1 added enhancement New feature or request kind and removed enhancement New feature or request kind labels Jan 21, 2021
@MajorHe1
Copy link
Contributor

ok, this feature looks good, you can do this by referring to defibus or rocketmq connector implementations

@keranbingaa
Copy link
Contributor

yes, you can implement the interface defined under the eventmesh-connector-api module, then pub/sub the events to kafka event store

@xwm1992
Copy link
Contributor Author

xwm1992 commented Jan 21, 2021

ok, i'll have a look and try to handle this feature.

@keranbingaa keranbingaa added the discussion This issue requires further discussion label Jan 21, 2021
@ruanwenjun
Copy link
Member

@xwm1992 Does any guys work for this issue, if there is no one, I will try to implement the Kafka connector.

@xwm1992
Copy link
Contributor Author

xwm1992 commented May 24, 2021

@xwm1992 Does any guys work for this issue, if there is no one, I will try to implement the Kafka connector.

@ruanwenjun no one has dealt with this issue yet, you are welcome to deal with it , looking forward your pull request.
you may create a new branch for version 1.3.0 to complete this feature is better.

@qqeasonchen
Copy link
Contributor

@ruanwenjun welcome to contribute.

@xwm1992
Copy link
Contributor Author

xwm1992 commented Jun 8, 2021

@ruanwenjun There are some problems with the KafkaMQProducerImplTest, please take a look
image

@ruanwenjun
Copy link
Member

@xwm1992 Thanks, I have resolved this problem.

@xwm1992
Copy link
Contributor Author

xwm1992 commented Jun 8, 2021

@xwm1992 Thanks, I have resolved this problem.

Ok, I will have a full test for your pull request by using kafka connector pub/sub messages.

ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 1, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 7, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 9, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 12, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 12, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 12, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 21, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Jul 27, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Aug 1, 2021
ruanwenjun added a commit to ruanwenjun/incubator-eventmesh that referenced this issue Aug 4, 2021
@Markliniubility
Copy link
Member

Hi I am working on this issue this summer!

qqeasonchen added a commit that referenced this issue Aug 26, 2022
[ISSUE #199] Kafka Connector: Initial Implementation of Consumer & Producer
xwm1992 pushed a commit that referenced this issue Sep 22, 2022
[ISSUE #199] Kafka Connector: Initial Implementation of Consumer & Producer
xwm1992 added a commit that referenced this issue Sep 26, 2022
[ISSUE #199] Kafka connector as event storage plugin
close #199
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment