Skip to content

[AURON #2093] Introduce kafka mock source#2106

Open
Tartarus0zm wants to merge 4 commits intoapache:masterfrom
Tartarus0zm:flink-mock-kafka-source
Open

[AURON #2093] Introduce kafka mock source#2106
Tartarus0zm wants to merge 4 commits intoapache:masterfrom
Tartarus0zm:flink-mock-kafka-source

Conversation

@Tartarus0zm
Copy link
Contributor

Which issue does this PR close?

Closes #2093

Rationale for this change

  • Since we don’t have a Kafka environment, testing is difficult; therefore, we’ve introduced a simulated Kafka source that allows us to specify the data to be sent, thereby achieving our testing objectives.

What changes are included in this PR?

  • add kafka_mock_scan_exec to send mock data
  • add support for specifying mock data in the Kafka Table Factory
  • add test AuronKafkaSourceITCase and AuronKafkaSourceTestBase

Are there any user-facing changes?

  • No

How was this patch tested?

  • test via UT

@Tartarus0zm Tartarus0zm requested a review from richox March 20, 2026 03:39
@Tartarus0zm Tartarus0zm requested a review from merrily01 March 20, 2026 04:58
@Tartarus0zm
Copy link
Contributor Author

@richox @merrily01 hello, CI is Green, PTAL

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 kafka mock source

1 participant