Could anyone point me to some sample code where I could get some insights on how to write a consumer to do the following: 1. poll at regular intervals 2. get a set of messages during each poll operation 3. process the messages, comit the offset Thanks, Joe