Add synced consuming and commit offsets method