flink-connector-rabbitmq
flink-connector-rabbitmq copied to clipboard
[FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19
Purpose of the change
Add SinkV2 implemetation for RabbitMQ.
Verifying this change
- Added unit tests for respective new implementations
- Added IT tests (moved to follow up PR to reduce PR size).
- Manually verified against local RabbitMQ cluster
Significant changes
(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)
- [x] Dependencies have been added or upgraded
- [ ] Public API has been changed (Public API is any class annotated with
@Public(Evolving)
) - [ ] Serializers have been changed
- [x] New feature has been introduced
- If yes, how is this documented? Follow up with another JIRA to update docs
Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
@MartijnVisser @zentol could you please review?
Any updates?
@paulh86 Blocked on review from the community, will reach out on dev slack channel for a reviewer
Hello,
What is the status of this PR?
Thanks
@rjbaucells Hello, It is pending approval from @MartijnVisser