Hi, everyone I’m pleased to announce that the Flink Native Kafka Source (based on Apache Auron(Incubating)) is now available. Features already implemented: Format:JSON and Protobuf Checkpoint:supported Watermark:supported How to Use? You need to compile from the Auron[1] Master branch, then place the `auron-flink-extension/auron-flink-assembly/target/auron-flink-assembly-*.jar` file in your Flink lib directory. Running a Flink job is similar to creating a Kafka table; you can refer to the Chinese docs[2] or the English docs[3]. If you're interested in Flink on Auron, please follow the Auron issues[4]. If you encounter any issues while using the product, please feel free to create an issue on the Auron community to provide feedback.
[1] https://github.com/apache/auron [2] https://docs.qq.com/doc/DR0d6SENOcGRPRGRn?no_promotion=1&is_blank_or_template=blank [3] https://docs.google.com/document/d/1SyNcMYI5QBajP0w-azoRNzXILrNHufkhGQcHhI9UOUs/edit?tab=t.0 [4] https://github.com/apache/auron/issues/1264 -- Best regards, Mang Zhang
