Skip to content

Introduce native flink kafka consumer #1847

@Tartarus0zm

Description

@Tartarus0zm

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

Sub-issues

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions