All pull requests

Pull requests

• [Issue 1543][consumer] Cancel in-flight ack requests when the broker closes the consumer

  #1562·EdwardShen125 opened Oct 28, 2026·1 task done·

  ·
  1

  13

• [Issue 1519][consumer] Give non-persistent topics a no-op acknowledgment grouping tracker

  #1561·EdwardShen125 opened Oct 27, 2026·1 task done·

  ·
  1

• [Issue 1554][client] Add ClientOptions.BackOffPolicyFunc to pace request retries

  #1560·EdwardShen125 opened Oct 27, 2026·1 task done·

  ·
  1

• fix(producer): set transaction ID on message metadata and don't batch across transactions

  #1559·jcmfernandes opened Oct 27, 2026Contributor·

  ·

• [fix][tableview] Cancel reader context in Close() to prevent potential deadlock

  #1558·zjxxzjwang opened Oct 27, 2026Contributor·1 task·

  ·
  5

• [fix][tableview] Fix watchReaderForNewMessages to exit silently on normal shutdown and skip nil messages on error

  #1557·zjxxzjwang opened Oct 27, 2026Contributor·

  ·
  10

  

• feat(pulsaradmin): support namespace delayed delivery policies

  #1549·freeznet opened Oct 17, 2026Contributor·1 task·

  ·
  1

  

• fix: prevent chunked producer self-deadlock when totalChunks > MaxPendingMessages

  #1540·n24q02m opened Sep 26, 2026·

  ·
  3

• [Issue 1536][txn] Synchronize transactional ACK topic registration

  #1537·Ebispongebob opened Sep 10, 2026·1 task·

  ·
  1

• [Issue 1534] Preserve batch size in transactional acknowledgments

  #1535·Ebispongebob opened Sep 9, 2026·1 task·

  ·
  1

• [Connection] Add an optional Dialer to ClientOptions

  #1532·SimonWoolf opened Aug 26, 2026·1 task·

  ·

• [Issue 1519][Consumer] Do not deduplicate messages on non-persistent topics

  #1520·VitorNathanG opened Jul 2, 2026·1 task done·

  ·
  1

• fix(deps): bump go-jose and OpenTelemetry to address security alerts

  #1516·merlimat opened Jun 22, 2026Contributor·1 task done·

  ·

• [feat][pip][consumer] Add Pause/Resume/Paused to Consumer

  #1507·PavelZeger opened May 30, 2026Contributor·1 task·

  ·
  1

  17

• fix(pulsar/internal): concurrent double reconnection loop in connecti…

  #1506·Skywalkr-dev opened May 25, 2026·

  ·
  1

• fix: prevent sendRequest double-done panic

  #1501·nodece opened May 20, 2026Member·

  ·
  1

  6

• fix: add transaction id to message metadata

  #1499·jiangmocc opened May 19, 2026·2 tasks done·

  ·
  1

  6

• feat(namespace): add individual namespace property management

  #1479·freeznet opened Apr 13, 2026Contributor·1 task·

  ·
  4

  

• chore(deps): bump go.opentelemetry.io/otel/sdk from 1.21.0 to 1.43.0

  dependenciesgo
  #1478·dependabot[bot] opened Apr 8, 2026Bot·

  ·
  3

• chore(deps): bump go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp from 1.19.0 to 1.43.0

  dependenciesgo
  #1477·dependabot[bot] opened Apr 8, 2026Bot·

  ·

• chore(deps): bump github.com/go-jose/go-jose/v4 from 4.0.5 to 4.1.4

  dependenciesgo
  #1474·dependabot[bot] opened Apr 3, 2026Bot·

  ·

• fix: update dependencies to resolve known CVEs

  #1472·henriklt opened Mar 20, 2026·

  ·
  3

• Feat/missing methods

  #1416·miton18 opened Sep 1, 2025Contributor·

  ·
  1

• [fix] Generate sequenceID at send time to ensure sequential ordering

  #1411·intkuroky opened Aug 27, 2025·

  ·
  4

• fix: move pulsarttracing from the internal to parent directory

  #1389·xuthus5 opened Jul 9, 2025Contributor·

  ·
  1