commits  

Messages by Thread

• (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
  • (pulsar) 01/01: [improve][misc] Add do/don't code examples for key conventions in CODING.md lhotari
• [I] [feature] Native support for AI agent ecosystem (MCP, agent runtime, agent communication) [pulsar] via GitHub
  • Re: [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
  • Re: [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
  • Re: [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] [fix][io] Fix loading offset issues in Kafka Adaptor [pulsar-connectors] via GitHub
  • Re: [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
  • Re: [PR] [feat][broker] PIP-475: regular-to-scalable topic migration command [pulsar] via GitHub
  • Re: [PR] [feat][broker] PIP-475: regular-to-scalable topic migration command [pulsar] via GitHub
  • Re: [PR] [feat][broker] PIP-475: regular-to-scalable topic migration command [pulsar] via GitHub
  • Re: [PR] [feat][broker] PIP-475: regular-to-scalable topic migration command [pulsar] via GitHub
  • Re: [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
  • Re: [PR] [fix][broker] Fix sub-microsecond precision loss in DataSketchesSummaryLogger#registerEvent [pulsar] via GitHub
  • Re: [PR] [fix][broker] Fix sub-microsecond precision loss in DataSketchesSummaryLogger#registerEvent [pulsar] via GitHub
  • Re: [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
  • Re: [PR] [pip] PIP-480: Add `readEntries` method to ManagedLedger [pulsar] via GitHub
  • Re: [PR] [pip] PIP-480: Add `readEntries` method to ManagedLedger [pulsar] via GitHub
  • Re: [PR] [pip] PIP-480: 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
  • Re: [I] [Bug] Kafka Connect Adaptor cannot load offsets when using non-JSON converters [pulsar-connectors] via GitHub
• [PR] Add support for extra init command to Broker STS upgrade for Istio si… [pulsar-helm-chart] via GitHub
  • Re: [PR] Add support for extra init command to Broker STS upgrade for Istio sidecar support [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
  • Re: [PR] [improve][functions] Allow customizing Kubernetes service domain suffix in Function Worker [pulsar] via GitHub
  • Re: [PR] [improve][functions] Allow customizing Kubernetes service domain suffix in Function Worker [pulsar] via GitHub
  • Re: [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
  • Re: [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
  • Re: [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
  • Re: [PR] Improve 25791 functions incremental reload [pulsar] via GitHub
  • Re: [PR] [improve][fn] #25791 functions incremental reload [pulsar] via GitHub
  • Re: [PR] [improve][fn] #25791 functions incremental reload [pulsar] via GitHub
  • Re: [PR] [improve][fn] #25791 functions incremental reload [pulsar] via GitHub
  • Re: [PR] [improve][fn] #25791 functions incremental reload [pulsar] via GitHub
  • Re: [PR] [improve][fn] make built-in functions reload incremental [pulsar] via GitHub
  • Re: [PR] [improve][fn] make built-in functions reload incremental [pulsar] via GitHub
  • Re: [PR] [improve][fn] make built-in functions reload incremental [pulsar] via GitHub
  • Re: [PR] [improve][fn] make built-in functions reload incremental [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
  • Re: [PR] Support protobuf native schema [pulsar-client-node] via GitHub
  • Re: [PR] Support protobuf native schema [pulsar-client-node] via GitHub
  • Re: [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: [PR] [fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests [pulsar] via GitHub
  • Re: [PR] [fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests [pulsar] via GitHub
  • Re: [PR] [fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests [pulsar] via GitHub
  • Re: [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
  • 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
  • Re: [PR] [fix][client-cpp] Fix TypedMessageTest to use receiveAsync<T> template overload with decoder [pulsar-client-cpp] via GitHub
  • Re: [PR] [fix][client-cpp] Fix TypedMessageTest to use receiveAsync<T> template overload with decoder [pulsar-client-cpp] via GitHub
  • Re: [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
  • Re: [PR] [fix][test] Stabilize WebService rate limiting test [pulsar] via GitHub
• [PR] Return 400 for invalid reader messageId query parameter [pulsar] via GitHub
  • Re: [PR] Return 400 for invalid reader messageId query parameter [pulsar] via GitHub
  • Re: [PR] Return 400 for invalid reader messageId query parameter [pulsar] via GitHub
  • Re: [PR] Return 400 for invalid reader messageId query parameter [pulsar] via GitHub
  • Re: [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
  • Re: [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
  • Re: [PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar] via GitHub
  • Re: [PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar] via GitHub
  • Re: [PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar] via GitHub
  • Re: [PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar] via GitHub
  • Re: [PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar] via GitHub
  • Re: [PR] [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) [pulsar] via GitHub
  • Re: [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
  • Re: [PR] [fix][broker] Fix compaction cursor reset may lose mark-delete properties [pulsar] via GitHub
  • Re: [PR] [fix][broker] Fix compaction cursor reset may lose mark-delete properties [pulsar] via GitHub
• [PR] [fix][io] Fix Solr Sink KeyValue schema unwrapping for Debezium CDC [pulsar-connectors] via GitHub
• (pulsar-site) branch dependabot/npm_and_yarn/qs-6.14.2 created (now 74cdcad1ef1) github-bot
• [PR] chore(deps): bump qs from 6.13.1 to 6.14.2 [pulsar-site] via GitHub
• [I] Geo-replication V2 dedup watermark can be lost after target topic reload [pulsar] via GitHub
• [PR] [fix][broker] Prevent duplicate geo-replicated messages after target topic reload [pulsar] via GitHub
  • Re: [PR] [fix][broker] Prevent duplicate geo-replicated messages after target topic reload [pulsar] via GitHub
• [I] [Improve][Offload] Automatic managed ledger offload triggers can create redundant retry loops [pulsar] via GitHub
• [I] [Bug][ML] ManagedLedger.terminate() can race with ledger rollover and make a terminated ledger writable again [pulsar] via GitHub
  • Re: [I] [Bug][ML] ManagedLedger.terminate() can race with ledger rollover and make a terminated ledger writable again [pulsar] via GitHub
• [PR] [fix][client] Avoid exception in ConsumerImpl hasMessageAvailable before first receive [pulsar] via GitHub
  • Re: [PR] [fix][client] Avoid exception in ConsumerImpl hasMessageAvailable before first receive [pulsar] via GitHub
• (pulsar) branch master updated: [improve][build] Upgrade kubernetes client-java to 26.0.0 (#25856) lhotari
• (pulsar) branch branch-4.0 updated (c05d2085fea -> cf214b08af3) lhotari
  • (pulsar) 01/03: [fix][test] Add timeout to initial receives in ResendRequestTest.testSharedSingleAckedPartitionedTopic (#25828) lhotari
  • (pulsar) 03/03: [improve][build] Remove kotlin-stdlib override; upgrade okhttp3 5.3.2 and okio 3.17.0 (#25855) lhotari
  • (pulsar) 02/03: [fix][test] Fix flaky ResendRequestTest.testSharedSingleAckedPartitionedTopic() test (#25852) lhotari
• (pulsar) branch branch-4.2 updated: [improve][build] Remove kotlin-stdlib override; upgrade okhttp3 5.3.2 and okio 3.17.0 (#25855) lhotari
• [PR] [improve][build] Upgrade kubernetes client-java to 26.0.0 and exclude AWS SDK transitives [pulsar] via GitHub
  • Re: [PR] [improve][build] Upgrade kubernetes client-java to 26.0.0 [pulsar] via GitHub
• (pulsar) branch branch-4.2 updated (e9ba10bd384 -> 4a5bf97af40) lhotari
  • (pulsar) 02/02: [fix][test] Fix flaky ResendRequestTest.testSharedSingleAckedPartitionedTopic() test (#25852) lhotari
  • (pulsar) 01/02: [fix][test] Add timeout to initial receives in ResendRequestTest.testSharedSingleAckedPartitionedTopic (#25828) lhotari
• (pulsar) branch master updated: [fix][test] Fix flaky ResendRequestTest.testSharedSingleAckedPartitionedTopic() test (#25852) lhotari
• (pulsar) branch master updated: [improve][build] Remove kotlin-stdlib override; upgrade okhttp3 5.3.2 and okio 3.17.0 (#25855) lhotari
• (pulsar) branch branch-4.0 updated (2e79ee3364f -> c05d2085fea) lhotari
  • (pulsar) 03/03: [fix][fn] Fix functions update issue where artifact is provided as a http url (#25840) lhotari
  • (pulsar) 01/03: [fix][broker] Fix ManagedLedgerImpl.advanceCursorsIfNecessary() method may lose non-durable cursor properties in race condition (#25796) lhotari
  • (pulsar) 02/03: [improve][fn] Avoid gRPC timeout when getting status of a dead process runtime (#25819) lhotari
• [PR] [improve][build] Remove kotlin-stdlib override; upgrade okhttp3 5.3.2 and okio 3.17.0 [pulsar] via GitHub
  • Re: [PR] [improve][build] Remove kotlin-stdlib override; upgrade okhttp3 5.3.2 and okio 3.17.0 [pulsar] via GitHub
• [PR] feat: introduce a v2 createProducer API to carry error message when fail [pulsar-client-cpp] via GitHub
  • Re: [PR] feat: introduce a v2 createProducer API to carry error message when fail [pulsar-client-cpp] via GitHub
  • Re: [PR] feat: introduce a v2 createProducer API to carry error message when fail [pulsar-client-cpp] via GitHub
  • Re: [PR] feat: introduce a v2 createProducer API to carry error message when fail [pulsar-client-cpp] via GitHub
  • Re: [PR] feat: introduce a v2 createProducer API to carry error message when fail [pulsar-client-cpp] via GitHub
• (pulsar) branch branch-4.2 updated (f9b8ac46118 -> e9ba10bd384) lhotari
  • (pulsar) 02/02: [fix][fn] Fix functions update issue where artifact is provided as a http url (#25840) lhotari
  • (pulsar) 01/02: [improve][fn] Avoid gRPC timeout when getting status of a dead process runtime (#25819) lhotari
• [PR] [improve][client] In cases where there is a risk of message loss, adjust the log level to error [pulsar] via GitHub
  • Re: [PR] [improve][client] In cases where there is a risk of message loss, adjust the log level to error [pulsar] via GitHub
• [I] [Sec] log4j: Improper serialization of non-finite floating-point values in JsonTemplateLayout #CVE-2026-34481 [pulsar] via GitHub
  • Re: [I] [Sec] log4j: Improper serialization of non-finite floating-point values in JsonTemplateLayout #CVE-2026-34481 [pulsar] via GitHub
  • Re: [I] [Sec] log4j: Improper serialization of non-finite floating-point values in JsonTemplateLayout #CVE-2026-34481 [pulsar] via GitHub
• [PR] fix: escape configuration values in UpdateDynamicConfiguration [pulsar-client-go] via GitHub
  • Re: [PR] fix: escape configuration values in UpdateDynamicConfiguration [pulsar-client-go] via GitHub
• (pulsar-client-node) branch dependabot/npm_and_yarn/multi-ac0ed4fa85 created (now 45f11c8) github-bot
• (pulsar) branch master updated: [improve][broker] PIP-473 P3.5: durable per-segment visibility state (#25821) lhotari
• (pulsar) branch master updated: [feat][client] PIP-475: V5 SDK consumes synthetic layouts for regular topics (#25850) lhotari
• [I] [PIP] Add `Pause()` / `Resume()` to `Consumer` [pulsar-client-go] via GitHub
  • Re: [I] [PIP] Add `Pause()` / `Resume()` to `Consumer` [pulsar-client-go] via GitHub
  • Re: [I] [PIP] Add `Pause()` / `Resume()` to `Consumer` [pulsar-client-go] via GitHub
  • Re: [I] [PIP] Add `Pause()` / `Resume()` to `Consumer` [pulsar-client-go] via GitHub
  • Re: [I] [PIP] Add `Pause()` / `Resume()` to `Consumer` [pulsar-client-go] via GitHub

• Earlier messages
• Later messages