Hi All, If I had Samza Tasks that were consuming message from multiple topics, how would checkpoint/commit work in that case? On calling taskCordinator.commit(), would current offset of all topics be saved for the caller task (only the partitions assigned to the caller task)? Is there a way to control this behavior more granularly where I can request samza to commit the offset for only a given task/topic combination only?
-- thanks, gaurav
