Best Approach to Consume Kafka Messages in Conductor OSS

Hi everyone,

Is there a way to consume Kafka messages using Conductor OSS?
I achieve this by creating a sample task using the consumer.poll method to retrieve messages. Is there a better approach for a worker to consume messages efficiently?

Looking forward to your insights!

Thanks!