An ack supported batch consumer, as well as  a real time stream consumer for kafka message queue. All in Java.