我猜测，要是可以在invoke的时候，拿到sink当前对应的barriar的话，从这个barriar取出offset，或者在richSinkFunction时，调用getRuntimeContext()上下文对象，从这个上下文中，拿到当前的task metrics，从而取出task的offset
-- Sent from: http://apache-flink.147419.n8.nabble.com/
- ??????????flink job ????????kafka source function ????????off... jasonwu
- Re: 请教如何在flink job 里自定义kafka source function 及时提交offset HideOnBushKi
