All pull requests

Pull requests

• fix(connectors): skip Iceberg rows that do not match the table schema

  S-waiting-on-review
  #4739·numinnex opened Nov 3, 2026Contributor·

  ·
  1

• test(integration): pin the crash loss of replicated partitions

  S-waiting-on-review
  #4738·numinnex opened Nov 3, 2026Contributor·

  ·
  1

• fix(server): clamp recovered consumer offsets after the WAL replay

  S-waiting-on-review
  #4737·numinnex opened Nov 3, 2026Contributor·

  ·
  1

  1

• fix(connectors): address Iceberg sink issues batch

  S-waiting-on-review
  #4736·numinnex opened Nov 3, 2026Contributor·

  ·
  5

  1

• feat(connectors): add RabbitMQ source connector

  S-waiting-on-review
  #4735·ygndotgg opened Nov 3, 2026Contributor·

  ·
  2

• feat(connectors): deliver sink messages at least once

  S-waiting-on-review
  #4734·numinnex opened Nov 3, 2026Contributor·

  ·
  3

  1

• fix: preserve JSON numbers and synchronize mux cancellation tests

  Prolific AuthorS-waiting-on-review
  #4733·tisonkun opened Nov 3, 2026Member·

  ·
  1

  1

• feat(connectors): add OpenSearch source connector

  #4730·ryerraguntla opened Nov 3, 2026Contributor·

  ·
  1

• test(web): reproduce overlapping newest-first message pages

  S-waiting-on-review
  #4719·Subham-KRLX opened Nov 3, 2026Contributor·

  ·
  1

• feat(examples): add PHP message envelope example

  S-waiting-on-review
  #4718·08abhinav opened Nov 3, 2026·

  ·
  1

  1

• feat(example): add a multi-tenant Go producer and consumer

  S-waiting-on-review
  #4716·chaitanya-y20 opened Nov 3, 2026·

  ·
  1

  2

• feat(examples): add python message envelope producer and consumer (#4696)

  S-waiting-on-review
  #4715·hrithiksaini99 opened Nov 3, 2026·

  ·
  1

  3

• feat(python): add sink data producer example

  S-waiting-on-review
  #4710·himanchalkaushale opened Nov 2, 2026·

  ·
  1

  2

• feat(connectors): add ScopeDB sink connector

  Prolific AuthorS-waiting-on-review
  #4708·tisonkun opened Nov 2, 2026Member·

  ·
  1

• refactor(partitions): move tests out of implementation modules

  S-waiting-on-review
  #4703·Surajsuthar opened Nov 2, 2026·

  ·
  1

  3

• chore(deps): Bump nlohmann_json from 3.12.0.bcr.1 to 3.12.0.bcr.2 in /foreign/cpp in the cpp group across 1 directory

  cppdependenciesS-waiting-on-review
  #4689·dependabot[bot] opened Oct 29, 2026Bot·

  ·

• feat(connectors): add OTLP sink for logs over HTTP (1/n)

  S-waiting-on-review
  #4682·ryankert01 opened Oct 29, 2026Member·

  ·
  2

• feat(cli): poll messages as a consumer group and follow new messages

  S-waiting-on-review
  #4680·marvelefe opened Oct 29, 2026·

  ·
  6

• fix(common): reject malformed user headers during deserialization

  S-waiting-on-review
  #4670·udaya-arka opened Oct 28, 2026·

  ·
  1

  18

• feat(python): add create_personal_access_token to the SDK

  S-waiting-on-author
  #4667·rkb32 opened Oct 28, 2026·

  ·
  1

  13

• chore(deps): Bump the github-actions group with 3 updates

  CI/CDdependenciesgithub-actionsS-waiting-on-review
  #4666·dependabot[bot] opened Oct 27, 2026Bot·

  ·
  1

• feat(python): expose consumer shutdown and offset drain timeout

  S-waiting-on-review
  #4660·ParthibanRajasekaran opened Oct 27, 2026Contributor·

  ·
  1

  2

• feat(connectors): add MSSQL CDC source connector

  S-waiting-on-review
  #4648·mattp5657 opened Oct 26, 2026Contributor·

  ·
  1

  2

• feat(web): add Dioxus web UI crate with streams browser

  S-waiting-on-review
  #4644·billy-doyle opened Oct 25, 2026·

  ·
  46

• test(go): cover access token command serialization

  S-waiting-on-review
  #4640·p4rtridge opened Oct 25, 2026·

  ·
  10