Skip to content

ref(kafka): Introduce MessageBackend for rdkafka and Arroyo messages - #809

Merged
lvthanh03 merged 1 commit into
mainfrom
tony/message-backend
Oct 7, 2026
Merged

lvthanh03 merged 1 commit into
mainfrom
tony/message-backend

Conversation

@lvthanh03

Copy link
Copy Markdown
Member

The consumer pipeline currently depends directly on rdkafka’s OwnedMessage. Introduce MessageBackend so deserialization, batching, error handling, and offset tracking can accept messages from either rdkafka or Arroyo.

Also bumps sentry_arroyo to 2.45.0.

@lvthanh03
lvthanh03 requested a review from a team as a code owner October 6, 2026 20:43
@lvthanh03
lvthanh03 merged commit aa27f88 into main Oct 7, 2026
28 checks passed
@lvthanh03
lvthanh03 deleted the tony/message-backend branch October 7, 2026 18:16
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants