Closed wengys closed 1 week ago
Could you add test case for this feature?
Could you add test case for this feature?
Sure, done. However I have no idea why test case testSinkRocketMq failed on Spark3 environment. Would you please give me a hand figure out why these test case failed?
Purpose of this pull request
Add static message tag support for RocketMQ sink
Does this PR introduce any user-facing change?
How was this patch tested?
Check list
release-note
.