All pull requests

Pull requests

• fix: enable debug logs when NUMAFLOW_DEBUG is set without RUST_LOG. Fixes #3453

  #3764·ShryukGrandhi opened Nov 4, 2026·

  ·
  1

  4

• feat: expose per-edge watermark as a pipeline daemon metric

  #3761·atishay-kasliwal opened Nov 3, 2026·

  ·
  1

• fix: bound ISB ack/nack retries by the consumer ack wait

  #3760·atishay-kasliwal opened Nov 3, 2026·

  ·
  1

  1

• fix: prevent scaling down a JetStream ISB Service

  #3759·atishay-kasliwal opened Nov 3, 2026·

  ·
  1

  5

• docs: use content tabs for reduce SDK examples

  #3758·atishay-kasliwal opened Nov 3, 2026·

  ·
  1

  3

• docs: use content tabs for user-defined source SDK examples

  #3757·atishay-kasliwal opened Nov 3, 2026·

  ·
  1

  2

• feat: log payload size when ISB message exceeds max payload

  #3756·atishay-kasliwal opened Nov 3, 2026·

  ·
  1

  2

• fix: skip already-settled offsets on pulsar ack/nack retry. Fixes #3659

  #3713·Yash121l opened Oct 12, 2026·

  ·
  1

  6

• ci: use self-hosted numaproj-runners, remove 13-job parallel cap

  #3705·dhyaneshnaikkaseya opened Oct 8, 2026·

  ·

• chore(docs): add built-in liveness and readiness probe defaults

  #3698·adarsh0728 opened Oct 6, 2026Member·

  ·
  1

• feat: support entry revision in kvstore

  #3681·vaibhavtiwari33 opened Sep 29, 2026Contributor·

  ·
  1

• feat[WIP]: additional methods for kvStore trait

  #3650·vaibhavtiwari33 opened Sep 16, 2026Contributor·

  ·

• feat: Numaflow CLI

  #3582·BulkBeing opened Aug 4, 2026Contributor·

  ·
  1

  

• chore: Docusaurus for documentations

  #3580·BulkBeing opened Aug 4, 2026Contributor·

  ·
  1

• fix: own pipeline cleanup job by its ISB Service to avoid deleting a recreated pipeline's buffers

  #3552·CameronMatthew opened Jul 20, 2026·

  ·
  16

• chore: traits for wal storage

  #3480·yhl25 opened Jun 23, 2026Contributor·

  ·

• feat: add platform-wide NUMAFLOW_LOG_LEVEL support

  #3410·adarsh0728 opened May 7, 2026Member·

  ·
  5

• [WIP] feat: errors endpoint rust impl for daemon mvtx

  #3296·KeranYang opened Mar 9, 2026Member·

  ·
  1

• test: test for map forwarder using simple buffer

  testing
  #3270·vaibhavtiwari33 opened Feb 26, 2026Contributor·

  ·
  1

  

• Sink optimizations - reduce message cloning

  #3189·BulkBeing opened Feb 4, 2026Contributor·

  ·
  3

• Feat/second nic communication

  #3129·sesame0224 opened Jan 8, 2026Contributor·

  ·
  19

• feat: option to disable exactly once

  #3104·yhl25 opened Dec 12, 2025Contributor·

  ·
  4

• content tabs and rust code for user-defined-functions/map

  #3034·ygxio opened Oct 22, 2025Contributor·

  ·
  1

  2

• [WIP] doc: add docs for batchSize

  #2897·kohlisid opened Aug 21, 2025Contributor·

  ·
  4

• fix: propogate health status for pipeline

  #2547·veds-g opened Apr 13, 2025Contributor·

  ·
  1

  2