[Enhancement] Fix the Kafka Consumer

[Markliniubility]

Search before asking

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

Enhancement Request

The Kafka Consumer is not yet fully implemented

Describe the solution you'd like

Implement the Kafka Consumer

Are you willing to submit PR?

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