Add consumer errors and clean up consumer code

[milindl]

Contains changes and error handling for the consumer.

---

We might need to take a deeper dive into seeing how auto-commit is handled, as well as multiple eachMessage's dispatched at once. Both of them are fairly critical features, and we have large semantic differences.

But I'll handle that in another PR, it needs some significant discussion.

[cla-assistant[bot]]

Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you all sign our Contributor License Agreement before we can accept your contribution.
1 out of 2 committers have signed the CLA.

:white_check_mark: milindl
:x: emasab
_{You have signed the CLA already but the status is still pending? Let us recheck it.}