Hi,
I'm implementing a custom SourceReader and want to base it on SourceReaderBase. However, it seems like while SourceReader and Source are part of `flink-core:1.11.1`, SourceReaderBase is not?
Do I need an external package for it?
--
Best Regards,
Yuval Itzchakov.