Closed banmoy closed 1 year ago
Fixes #
Add IT framework for pipeline from kakfka to starrocks. It refers to Flink's KafkaChangelogTableITCase.
What type of PR is this:
Which issues of this PR fixes :
Fixes #
Problem Summary(Required) :
Add IT framework for pipeline from kakfka to starrocks. It refers to Flink's KafkaChangelogTableITCase.
Checklist: