flink-connector-rabbitmq icon indicating copy to clipboard operation
flink-connector-rabbitmq copied to clipboard

[FLINK-21373] Add RabbitMQ SinkV2 Implementation, Port Flink version to Flink 1.19

Open vahmed-hamdy opened this issue 9 months ago • 7 comments

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

vahmed-hamdy avatar May 02 '24 14:05 vahmed-hamdy

Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)

boring-cyborg[bot] avatar May 02 '24 14:05 boring-cyborg[bot]

@MartijnVisser @zentol could you please review?

vahmed-hamdy avatar May 03 '24 08:05 vahmed-hamdy

Any updates?

paulh86 avatar Jul 03 '24 11:07 paulh86

@paulh86 Blocked on review from the community, will reach out on dev slack channel for a reviewer

vahmed-hamdy avatar Jul 11 '24 16:07 vahmed-hamdy

Hello,

What is the status of this PR?

Thanks

rjbaucells avatar Jul 22 '24 15:07 rjbaucells

@rjbaucells Hello, It is pending approval from @MartijnVisser

vahmed-hamdy avatar Aug 15 '24 14:08 vahmed-hamdy