Skip to content

[AURON #2058] Introduce KafkaScanExec#2072

Merged
Tartarus0zm merged 5 commits intoapache:masterfrom
Tartarus0zm:auron-kafka-consumer
Mar 6, 2026
Merged

[AURON #2058] Introduce KafkaScanExec#2072
Tartarus0zm merged 5 commits intoapache:masterfrom
Tartarus0zm:auron-kafka-consumer

Conversation

@Tartarus0zm
Copy link
Contributor

Which issue does this PR close?

Closes #2058

Rationale for this change

  • add native kafka consumer

What changes are included in this PR?

  • add Protobuf Node : KafkaScanExecNode
  • add Native kafka_scan_exec.rs

Are there any user-facing changes?

  • No

How was this patch tested?

  • No need test for kafka_scan_exec.rs
  • kafka_scan_exec#test_flink_kafka_partition_assign Validate Kafka partition allocation strategy.

@Tartarus0zm
Copy link
Contributor Author

@richox CI is green, PTAL

@Tartarus0zm Tartarus0zm merged commit 0aa013a into apache:master Mar 6, 2026
112 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Introduce KafkaScanExec

2 participants