Hey, You can take JDBCTableSource [1] as an example about how to implement a LookupableTableSource. However, I'm not sure how to support lookup for kafka. Because AFAIK, kafka doesn't have the ability to lookup by key?
Best, Jark [1]: https://github.com/apache/flink/blob/master/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSource.java On Tue, 21 Apr 2020 at 19:44, Clay Teeter <clay.tee...@maalka.com> wrote: > Hey, does anyone have any examples that i can use to create a > LookupableTableSource from a kafka topic? > > Thanks! > Clay > >
