Kafka Connector In Mule


Kafka connector helps you to interact with Apache Kafka Messaging system and provide seamless integration between mule application and apache messaging system

Operation available:

  • Commit: Commits the offsets associated to a message or batch of messages consumed in a Message Listener
  • Consume: This operation is used to receive the message from one or more kafka topic.
  • Message Listener: This source supports the consumption of messages from a Kafka Cluster, producing a single message to the flow, it works similar to consume
  • Publish: This operation is used to publish message to specified kafka topic, publish operation support the transactions
  • Seek: Sets the current offset value for the given topic, partition and consumer group of the listener
Thank you for taking out time to read the above post. Hope you found it useful. In case of any questions, feel free to comment below. Also, if you are keen on knowing about a specific topic, happy to explore your recommendations as well.
For any latest updates or posts on our website, you can follow us on LinkedIn. Look forward to connecting with you there.

Share this:
Notify of
Inline Feedbacks
View all comments