You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by hao kong <ha...@lemonbox.me> on 2021/01/08 16:28:57 UTC

flink1.12的kafka source 和 OperatorCoordinator

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