However due to the nature of Kafka this is very difficult to make work right especially if you need to run multiple instances of your application because Kafka topics are partitioned and there can only be one consumer per partition.