flink-connector-rabbitmq

flink-connector-rabbitmq copied to clipboard

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

15

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

[FLINK-36595][docs] Explicitly set connector compatibility as string …

1

Explicitly set connector compatibility as string to prevent version comparison mismatch ### Purpose of the change * Set version as string to prevent version comparison mismatch. Issue has happened for...

nicusX

Bumps org.apache.commons:commons-lang3 from 3.14.0 to 3.18.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...

dependabot[bot]