how to save task from apache consumer which are send from apache producer in kafka?

I want to create a queue management system which can handle multiple queues at a time by using Apache Kafka. So I am sending the tasks to producer and consumer to store them into Kafka through a rule engine. I Don't know how to start.