Create a consumer that works locally

[john-z-yang]

Problem statement

Create a consumer that works on locally environment, it must be able to have:

• Graceful shutdown
• Partition rebalancing handling
• Some kind of error mechanism