catch more exceptions and retry

cactching few more exceptions and consumer offest commit guarantee

working transactions. tagging for future rework