flink1.12的kafka source 和 OperatorCoordinator

[hao kong]

hello，我一直在关注FLIP-27实现的全新source，更新1.12后发现了已经有新的kafkasource实现，目前在使用kafkasource与coordinator通信的时候遇到了困难。
我创建了一个kafkasource和对应的operatorCoordinator，并在source上create了一个reader，在operatorCoordinator的handleEventFromOperator上打了一个断点，在启动的时候能够成功收到注册reader的消息，但是无法收到其他通过sourceReaderContext的sendSourceEventToCoordinator发送的sourceEvent，主要原因是不知道如何去new一个sourceReaderContext，请问是否有相应的代码例子呢？