Manually Commit Offset When Partition Revoked

[jlcarpenter]

I have a long running message while processing a file where the partition is sometimes revoked. I have a handler that is called when this happens. Is it possible to commit the offset when that occurs? I've tried different things in the handler and can't figure out a way to get an instance of the consumer to commit the offset or commit another way.