All pull requests

Pull requests

• perf(gateways): give each Kafka producer its own Iggy client

  S-waiting-on-review
  #4502·krishvishal opened Oct 12, 2026Member·

  ·
  1

• fix(sdk): drop the oldest diagnostic event instead of blocking

  S-waiting-on-review
  #4501·TomPlanche opened Oct 12, 2026Contributor·

  ·
  1

  4

• fix(consensus): keep committed ops when restarted replicas elect

  S-waiting-on-review
  #4500·numinnex opened Oct 12, 2026Contributor·

  ·

• feat(cluster): add three-node Docker Compose cluster

  S-waiting-on-review
  #4499·justinmclean opened Oct 12, 2026Member·

  ·
  1

  1

• feat(go): parse iggy:// connection strings into TCP client options

  S-waiting-on-author
  #4497·choksi2212 opened Oct 12, 2026·

  ·
  1

  25

• feat(go): add snapshot support

  S-waiting-on-author
  #4493·itsWill opened Oct 12, 2026Contributor·

  ·
  1

  10

• feat(python): expose get_cluster_metadata

  S-waiting-on-review
  #4490·SunilKumarPradhan opened Oct 12, 2026·

  ·
  1

  12

• cli: adding support for partition and lag listing

  #4489·BlackPanther112358 opened Oct 11, 2026·

  ·
  1

  2

• feat(server): disk usage accounting

  S-waiting-on-author
  #4488·andreinnanu opened Oct 11, 2026·

  ·
  17

• fix(connectors): exclude key and version from connector env mappings

  S-waiting-on-author
  #4486·Mitshah2406 opened Oct 10, 2026·

  ·
  1

  11

• test(consensus): expose committed-op loss in probe-exhaustion election

  S-waiting-on-review
  #4485·numinnex opened Oct 9, 2026Contributor·

  ·
  1

• fix(partitions): finish state transfer for a replica whose view ran ahead

  S-waiting-on-review
  #4483·numinnex opened Oct 9, 2026Contributor·

  ·
  1

  1

• fix(go): reject malformed user headers in NewIggyMessage

  S-waiting-on-review
  #4481·numinnex opened Oct 9, 2026Contributor·

  ·
  1

  1

• feat(server): expose per-topic size and message count on /metrics

  S-waiting-on-review
  #4480·numinnex opened Oct 9, 2026Contributor·

  ·
  1

  4

• feat(cli): support IGGY_TOKEN environment variable

  S-waiting-on-review
  #4478·Mola-maker opened Oct 9, 2026·

  ·
  1

  9

• test(cluster): add a docker chaos harness for multi-node edge cases

  S-waiting-on-review
  #4474·almostintuitive opened Oct 9, 2026Contributor·

  ·
  2

• test(go): fail when NewIggyMessage accepts headers no reader can decode

  S-waiting-on-review
  #4472·almostintuitive opened Oct 9, 2026Contributor·

  ·
  2

• ci: add job timeouts and stagger the stale-PR cron

  S-waiting-on-author
  #4466·justinmclean opened Oct 8, 2026Member·

  ·
  1

  6

• fix(consensus): retry the primary's own write on prepare timeout

  S-waiting-on-review
  #4457·numinnex opened Oct 8, 2026Contributor·

  ·
  1

  1

• fix(ci): replace pull_request_target in PR triage and stale unmark

  S-waiting-on-review
  #4455·justinmclean opened Oct 8, 2026Member·

  ·
  1

  2

• fix(ci): cap pre-merge job concurrency under the ASF limit

  S-waiting-on-review
  #4454·justinmclean opened Oct 8, 2026Member·

  ·
  1

  3

• test(integration): add primary-side torn-tail crash recovery specs

  S-waiting-on-review
  #4442·numinnex opened Oct 8, 2026Contributor·

  ·
  1

  1

• test(partitions): reproduce a lagging replica stuck in state transfer

  S-waiting-on-review
  #4439·almostintuitive opened Oct 8, 2026Contributor·

  ·
  2

• test(sdk): fail when sends to split partition primaries move the session

  S-waiting-on-review
  #4437·almostintuitive opened Oct 7, 2026Contributor·

  ·
  2

• fix(partitions): make writer-lease drain wait executor-agnostic

  S-waiting-on-review
  #4434·numinnex opened Oct 7, 2026Contributor·

  ·
  1

  1