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!