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

Reply via email to