Skip to content

[AURON #2093] Introduce kafka mock source#2106

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

[AURON #2093] Introduce kafka mock source#2106
Tartarus0zm wants to merge 2 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

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