Skip to content

feat(connectors): add RabbitMQ sink - #3811

Open
amr8t wants to merge 2 commits into
apache:masterfrom
amr8t:rabbitmq_sink
Open

feat(connectors): add RabbitMQ sink#3811
amr8t wants to merge 2 commits into
apache:masterfrom
amr8t:rabbitmq_sink

Conversation

@amr8t

@amr8t amr8t commented Aug 3, 2026

Copy link
Copy Markdown

Which issue does this PR address?

Relates to #3747

Sumary

This change adds the RabbitMQ sink connector via the lapin client. As requested, doing only sink connector in this PR. Source will be a separate one.

Adds Configurable exchange and various types (topic, direct, fanout).
Adds Configurable Retries with exponential backoff
Added Integration tests against RabbitMQ container covering topic, fanout and direct exchange behavior.

Local Execution

Completed below based on https://github.com/apache/iggy/blob/master/CONTRIBUTING.md

  • Quality Checks
  • Typos Checks
  • License Header Checks
  • Pre-commit Hooks

@github-actions

github-actions Bot commented Aug 3, 2026

Copy link
Copy Markdown

Thanks for the PR. It is labeled S-waiting-on-review and queued for review.

Slash commands (own line, regular comment) move it around the queue:

  • /ready - back to S-waiting-on-review after addressing feedback
  • /author - flip to S-waiting-on-author while you finish changes
  • /request-review @user-or-team - request a reviewer

See CONTRIBUTING.md for details.

@github-actions github-actions Bot added the S-waiting-on-review PR is waiting on a reviewer label Aug 3, 2026
@codecov

codecov Bot commented Aug 3, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 43.31551% with 106 lines in your changes missing coverage. Please review.
✅ Project coverage is 75.54%. Comparing base (2e1cbfa) to head (88abbad).
⚠️ Report is 6 commits behind head on master.

Files with missing lines Patch % Lines
core/connectors/sinks/rabbitmq_sink/src/lib.rs 43.31% 100 Missing and 6 partials ⚠️
Additional details and impacted files
@@             Coverage Diff              @@
##             master    #3811      +/-   ##
============================================
- Coverage     75.62%   75.54%   -0.09%     
  Complexity     1046     1046              
============================================
  Files          1337     1338       +1     
  Lines        169125   169312     +187     
  Branches     141481   141745     +264     
============================================
- Hits         127907   127906       -1     
- Misses        37435    37527      +92     
- Partials       3783     3879      +96     
Components Coverage Δ
Rust Core 75.41% <43.31%> (-0.06%) ⬇️
Java SDK 63.67% <ø> (ø)
C# SDK 71.13% <ø> (-1.14%) ⬇️
Python SDK 88.14% <ø> (ø)
PHP SDK 82.97% <ø> (ø)
Node SDK 96.36% <ø> (+0.08%) ⬆️
Go SDK 43.08% <ø> (ø)
Files with missing lines Coverage Δ
core/connectors/sinks/rabbitmq_sink/src/lib.rs 43.31% <43.31%> (ø)

... and 50 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
  • 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

@amr8t

amr8t commented Aug 5, 2026

Copy link
Copy Markdown
Author

/request-review @hubcio

@github-actions
github-actions Bot requested a review from hubcio August 5, 2026 20:29
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

S-waiting-on-review PR is waiting on a reviewer

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant