flink-connector-rabbitmq

flink-connector-rabbitmq copied to clipboard

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

7

## 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...

vahmed-hamdy

[FLINK-20628] RabbitMQ Connector using FLIP-27 Source API

15

## What is the purpose of the change This pull request ports the RabbitMQ connector implementation to the new Connector’s API described in [FLIP-27](https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface) and [FLIP-143](https://cwiki.apache.org/confluence/display/FLINK/FLIP-143%3A+Unified+Sink+API). It includes both source...

pscls

[FLINK-20628] Port RabbitMQ Connector using unified Source & Sink API

1

related pr #1

RocMarshal