catch more exceptions and retry
cactching few more exceptions and consumer offest commit guarantee
working transactions. tagging for future rework