I'm using flink 1.17.1 and can't find the classes expressed on this documentation: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/datagen/ https://nightlies.apache.org/flink/flink-docs-release-1.17/api/java//org/apache/flink/connector/datagen/source/GeneratorFunction.html Any tips? I'm trying to mock a kafka source for a test.

I'm not sure what you're trying to achieve; Datagen is a random data generator, while you're talking about mocking a Kafka source. Wouldn't it make more sense to create a bounded Kafka connector?

I want to read from a file in the tests but from kafka in prod. With the sink we can just implement the

SinkFunction

interface, but with the new

Source

I can't do the same because it's too complex. So I was trying to use this: https://cwiki.apache.org/confluence/display/FLINK/FLIP-238%3A+Introduce+FLIP-27-based+Data+Generator+Source "At the same time, it is frequently required to generate arbitrary events with a "mock" source."

I think the Flink example are just updated to reflect those changes