Introduce native flink kafka consumer
Open
- Dominant language
- Rust
- Stars
- 1.8k
- Forks
- 241
- Avg merge
- 2d 12h
- Merged PRs (30d)
- 21
Description
Using the Native Flink Kafka Consumer enables Native operators to be more robust and efficient.
- Kafka partition allocation strategies must align with Flink.
- Supports Flink Checkpoint
- Supports Flink Watermark
Contributor guide
Assessment
This issue has not been assessed yet.