Messages by Thread
-
[D] Should we expose an IO‑thread level publish buffer backpressure metric? [pulsar]
via GitHub
-
[I] Upgrade opentelemetry-api to 1.62.0 due to CVE-2026-45292 [pulsar]
via GitHub
-
[I] Upgrade org.apache.commons_commons-configuration2 to 2.15.1 due to CVE-2026-45205 [pulsar]
via GitHub
-
[PR] Fix byte integer converter overflow [pulsar]
via GitHub
-
[I] [PIP] Add `StartPaused` option to `ConsumerOptions` [pulsar-client-go]
via GitHub
-
[PR] [fix][test] Stabilize testSecondaryIsolationGroupsBookiesNegative() test [pulsar]
via GitHub
-
[PR] [feat][pip][consumer] Add Pause/Resume/Paused to Consumer [pulsar-client-go]
via GitHub
-
[PR] [fix][client] Prevent duplicate ServiceUrlProvider initialization [pulsar]
via GitHub
-
[I] [Bug] ControlledClusterFailover.close loses the underlying exception [pulsar]
via GitHub
-
(pulsar) branch master updated: [fix][test] Fix flaky PulsarFunctionTlsTest.testFunctionsCreation() test (#25889)
lhotari
-
[I] [Bug] OTel producer spans can report incorrect topic for partitioned producers [pulsar]
via GitHub
-
[PR] [fix][client] Fix incorrect topic in OTel spans for partitioned producers [pulsar]
via GitHub
-
[I] [Bug] OTel consumer spans use incorrect topic for multi-topic consumers [pulsar]
via GitHub
-
[PR] Fix OTel consumer destination topic [pulsar]
via GitHub
-
[PR] [fix][client] Handle synchronous RetryUtil supplier failures [pulsar]
via GitHub
-
[PR] [fix][test] Fix flaky SameAuthParamsLookupAutoClusterFailoverTest.testAutoClusterFailover() test [pulsar]
via GitHub
-
[PR] [feat] Add RandomReader to Pulsar client [pulsar]
via GitHub
-
[PR] [feat][pip] PIP-478: Asynchronous v5 client auth plugin interfaces and TLS material provider plugin interface [pulsar]
via GitHub
-
[PR] [fix][test] Fix flaky PulsarFunctionTlsTest.testFunctionsCreation() test [pulsar]
via GitHub
-
[PR] [improve][test] Migrate pulsar-perf to the V5 client API [pulsar]
via GitHub
-
(pulsar) branch master updated: [fix][broker] Fix non-batched null-value messages not removed during topic compaction (#25817)
lhotari
-
[PR] Upgrade BookKeeper dependency to 4.18.0 [pulsar]
via GitHub
-
(pulsar-client-cpp) annotated tag v4.2.0-candidate-1 updated (bc08a50 -> 5bcf23c)
xyz
-
(pulsar-client-cpp) branch branch-4.2 created (now ee192c9)
xyz
-
(pulsar-client-node) branch dependabot/npm_and_yarn/fast-uri-3.1.2 deleted (was 680ce02)
github-bot
-
(pulsar-client-node) branch master updated: Bump fast-uri from 3.1.0 to 3.1.2 (#483)
baodi
-
(pulsar-client-cpp) branch main updated: Fix macOS cross-architecture build on arm64 when target arch is x86_64 (#582)
baodi
-
[PR] Fix macOS cross-architecture build on arm64 when target arch is x86_64 [pulsar-client-cpp]
via GitHub
-
[I] [Fn][Observability] Status of OpenTelemetry metrics support (PIP-264/PIP-320) [pulsar]
via GitHub
-
[PR] [improve][broker] PIP-473 P5.2: scalable-topics TC timeout + GC sweeps [pulsar]
via GitHub
-
(pulsar) branch master updated: [fix][client] PIP-475: make async producer survive regular-to-scalable migration (#25882)
lhotari
-
(pulsar-client-cpp) annotated tag v4.2.0-candidate-1 updated (e420b4d -> bc08a50)
xyz
-
(pulsar-client-cpp) branch main updated: feat: add v2 APIs to create Consumer, Reader or TableView (#581)
baodi
-
[PR] feat: add v2 APIs to create Consumer, Reader or TableView [pulsar-client-cpp]
via GitHub
-
[PR] Embed native image config [pulsar]
via GitHub
-
[PR] [fix][client] PIP-475: make async producer survive regular-to-scalable migration [pulsar]
via GitHub
-
(pulsar) branch master updated: [improve][proxy] Support scalable topics through the proxy (#25879)
lhotari
-
(pulsar) branch master updated: [test][broker] PIP-475: end-to-end migration tests + transition fixes (#25878)
lhotari
-
(pulsar) branch master updated: [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) (#25863)
lhotari
-
(pulsar) branch master updated: [improve][misc] Add AGENTS.md and split build/contributor/coding/architecture/security docs (#25871)
lhotari
-
(pulsar) branch lh-support-webservice-bindaddresses-and-advertised-listeners deleted (was 005ae15df34)
lhotari
-
(pulsar) branch revert-24732-fix-key-shared-bug-23845 deleted (was 9183d3c9e3f)
lhotari
-
(pulsar) branch lh-test-pr23851 deleted (was 99730fa592b)
lhotari
-
(pulsar) branch lh-AGENTS.md deleted (was e8c836a118d)
lhotari
-
(pulsar) branch lh-AGENTS.md created (now e8c836a118d)
lhotari
-
[I] [feature] Native support for AI agent ecosystem (MCP, agent runtime, agent communication) [pulsar]
via GitHub
-
(pulsar) branch master updated: [fix][bk] Fix NPE in IsolatedBookieEnsemblePlacementPolicy when policy class does not match (#25825)
daojun
-
[PR] [feat][pip] PIP-480: Add `readEntries` method to ManagedLedger [pulsar]
via GitHub
-
[PR] [improve][proxy] Support scalable topics through the proxy [pulsar]
via GitHub
-
[PR] [test][broker] PIP-475: end-to-end migration tests + transition fixes [pulsar]
via GitHub
-
(pulsar) branch master updated: [feat][broker] PIP-475: regular-to-scalable topic migration command (#25875)
mmerli
-
[I] Add a way to add annotations to batch/v1 / Job object templates [pulsar-helm-chart]
via GitHub
-
[PR] Fix bandwidth-in quota update check [pulsar]
via GitHub
-
[PR] Fix MathUtils ceilDiv integer overflow [pulsar]
via GitHub
-
[PR] [fix][io] Fix loading offset issues in Kafka Adaptor [pulsar-connectors]
via GitHub
-
Re: [PR] [improve][pip] PIP-438: add namespace topics limit metric [pulsar]
via GitHub
-
Re: [PR] [improve][broker] add namespace topics limit metric [pulsar]
via GitHub
-
[PR] [feat][broker] PIP-475: regular-to-scalable topic migration command [pulsar]
via GitHub
-
(pulsar-helm-chart) branch master updated: Add support for extra init command to Broker STS upgrade for Istio sidecar support. (#688)
lhotari
-
Re: [I] [Doc] Description for Producer SendAsync Needs Updating [pulsar]
via GitHub
-
(pulsar-client-go) branch master updated: docs(producer): clarify SendAsync description (#1485)
crossoverjie
-
[PR] [fix][broker] Fix sub-microsecond precision loss in DataSketchesSummaryLogger#registerEvent [pulsar]
via GitHub
-
(pulsar-client-cpp) branch main updated: feat: introduce a v2 createProducer API to carry error message when fail (#579)
xyz
-
(pulsar) branch branch-4.2 updated: [fix][client] Fix failed to close consumer because of the error: param memorySize is a negative value (#25805)
yubiao
-
(pulsar) branch branch-4.0 updated: [fix][client] Fix failed to close consumer because of the error: param memorySize is a negative value (#25805)
yubiao
-
(pulsar) branch branch-4.0 updated: [fix][client]Fix checkstyle issue of ConsumerBase.java
yubiao
-
(pulsar) branch branch-4.2 updated: [improve][client] In cases where there is a risk of message loss, adjust the log level to error (#25854)
yubiao
-
(pulsar) branch branch-4.0 updated: [improve][client] In cases where there is a risk of message loss, adjust the log level to error (#25854)
yubiao
-
[PR] PIP-475: Add `readEntries` method to ManagedLedger [pulsar]
via GitHub
-
(pulsar) branch revert-25851-lh-simplify-listener-config-and-support-proxyless-admin-api created (now 849f11fde37)
zixuan
-
[I] [Bug] Kafka Connect Adaptor cannot load offsets when using schema registry [pulsar-connectors]
via GitHub
-
[PR] Add support for extra init command to Broker STS upgrade for Istio si… [pulsar-helm-chart]
via GitHub
-
[I] [Bug] Kafka Connect Adaptor ignores converter configurations [pulsar-connectors]
via GitHub
-
(pulsar-client-cpp) branch main updated: [fix][client-cpp] Fix TypedMessageTest to use receiveAsync<T> template overload with decoder (#580)
xyz
-
(pulsar-client-cpp) branch main updated: [improve][client] Implement tls_client_auth for AuthOauth2 (#575)
xyz
-
[PR] [improve][functions] Allow customizing Kubernetes service domain suffix in Function Worker [pulsar]
via GitHub
-
(pulsar) branch master updated: [improve][misc] Upgrade Netty to 4.1.134 (#25870)
lhotari
-
[PR] [improve][misc] Add AGENTS.md and refresh contributor/agent convention docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and refresh contributor/agent convention docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and refresh contributor/agent convention docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and refresh contributor/agent convention docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and refresh contributor/agent convention docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and refresh contributor/agent convention docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and restructure contributor/agent docs with .agents/skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split contributor/coding/architecture/security docs, with .agents skills [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split build/contributor/coding/architecture/security docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split build/contributor/coding/architecture/security docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split build/contributor/coding/architecture/security docs [pulsar]
via GitHub
-
Re: [PR] [improve][misc] Add AGENTS.md and split build/contributor/coding/architecture/security docs [pulsar]
via GitHub
-
[PR] [improve][misc] Upgrade Netty to 4.1.134 [pulsar]
via GitHub
-
[PR] [fix][fn] Fix Go function incorrectly using nanoseconds for timestamp [pulsar]
via GitHub
-
(pulsar-client-node) branch dependabot/npm_and_yarn/multi-ac0ed4fa85 updated (45f11c8 -> 7b8c821)
github-bot
-
(pulsar-client-node) branch master updated: Support protobuf native schema (#486)
xyz
-
[PR] Improve 25791 functions incremental reload [pulsar]
via GitHub
-
(pulsar) branch master updated: [fix][broker] Fix PersistentMessageExpiryMonitor findEntryComplete() method may lose mark-delete properties in race condition (#25803)
lhotari
-
(pulsar) branch master updated: Return 400 for invalid reader messageId query parameter (#25865)
lhotari
-
(pulsar) branch master updated: [fix][client] Fix failed to close consumer because of the error: param memorySize is a negative value (#25805)
lhotari
-
(pulsar) branch master updated: [fix][broker] Fix compaction cursor reset may lose mark-delete properties (#25862)
lhotari
-
(pulsar) branch master updated: [fix][test] Fix flaky ProducerCleanupTest timer cleanup (#25864)
lhotari
-
(pulsar) branch master updated: [fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests (#25867)
lhotari
-
[PR] Support protobuf native schema [pulsar-client-node]
via GitHub
-
(pulsar-client-node) branch master updated: Set up default protection ruleset for default and release branches (#484)
baodi
-
[PR] [fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests [pulsar]
via GitHub
-
Re: [I] Consumer message loss due to duplicate reconnection [pulsar-client-go]
via GitHub
-
[PR] fix(pulsar/internal): concurrent double reconnection loop in connecti… [pulsar-client-go]
via GitHub
-
Re: [PR] [improve][test] Add filtering solution for fast selection of TestNG groups [pulsar]
via GitHub
-
[PR] [fix][client-cpp] Fix TypedMessageTest to use receiveAsync<T> template overload with decoder [pulsar-client-cpp]
via GitHub
-
(pulsar) branch master updated: [fix][test] Stabilize WebService rate limiting test (#25866)
lhotari
-
Re: [I] Add tests with BlockHound [pulsar-client-reactive]
via GitHub
-
[PR] [fix][test] Stabilize WebService rate limiting test [pulsar]
via GitHub
-
[PR] Return 400 for invalid reader messageId query parameter [pulsar]
via GitHub
-
[PR] [fix][io] Prevent OOM in FileSource by bounding internal queues [pulsar-connectors]
via GitHub
-
(pulsar) branch master updated: [improve][client] In cases where there is a risk of message loss, adjust the log level to error (#25854)
yubiao
-
[PR] [fix][test] Fix flaky ProducerCleanupTest timer cleanup [pulsar]
via GitHub
-
[PR] [fix][io] Interrupt Kafka Source instance thread on consumer fatal error to prevent deadlock [pulsar-connectors]
via GitHub
-
[PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar]
via GitHub
-
[PR] [fix][broker] Fix compaction cursor reset may lose mark-delete properties [pulsar]
via GitHub