[Enhancement] Support Kafka connector plugin: Kafka Consumer

[Markliniubility]

trafficstars

Search before asking

• [X] I had searched in the issues and found no similar issues.

Enhancement Request

A sub-issue of #199 (Support Kafka connector to deliver event to Kafka). The consumer is a necessary and important milestone for the completion of #199.

Describe the solution you'd like

As the Cloudevent has already supported Kafka, we no longer need to write messageFactory ourselves. We may write the consumer directly.

Are you willing to submit PR?

• [X] Yes I am willing to submit a PR!

[github-actions[bot]]

Welcome to the Apache EventMesh (incubating) community!! We are glad that you are contributing by opening this issue. :D

Please make sure to include all the relevant context. We will be here shortly.

If you are interested in contributing to our project, please let us know! You can check out our contributing guide on contributing to EventMesh.

Want to get closer to the community?

WeChat Group：

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