commits  

Messages by Thread

• (pulsar) branch master updated: [improve][broker] Log only non-default config values on broker startup (#25545) mmerli
• [PR] [fix][sec] Upgrade to async-http-client 2.14.5 to address CVE [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade to async-http-client 2.14.5 to address CVE [pulsar] via GitHub
• (pulsar) branch master updated: [improve] PIP-467: Convert Jetty request logs to structured slog events (#25543) mmerli
• [PR] [improve][broker] Log only non-default config values on broker startup [pulsar] via GitHub
  • Re: [PR] [improve][broker] Log only non-default config values on broker startup [pulsar] via GitHub
• (pulsar) branch master updated: [improve] PIP-467: Remove now-dead slf4j.api dependency from modules converted to slog (#25541) mmerli
• (pulsar) branch master updated: [improve][misc] Add deepwiki badge in README to enable automated index update (#25544) mmerli
• (pulsar) branch master updated: [improve] Emit flat OpenTelemetry JSON logs instead of ECS (#25542) mmerli
• [PR] [improve][misc] Add deepwiki badge in README to enable automated index update [pulsar] via GitHub
  • Re: [PR] [improve][misc] Add deepwiki badge in README to enable automated index update [pulsar] via GitHub
• (pulsar-site) branch main updated: Add "Ask DeepWiki" badge to keep the wiki up-to-date lhotari
• [PR] [improve] PIP-467: Convert Jetty request logs to structured slog events [pulsar] via GitHub
  • Re: [PR] [improve] PIP-467: Convert Jetty request logs to structured slog events [pulsar] via GitHub
• [PR] [improve] Emit flat OpenTelemetry JSON logs instead of ECS [pulsar] via GitHub
  • Re: [PR] [improve] Emit flat OpenTelemetry JSON logs instead of ECS [pulsar] via GitHub
• [PR] [improve] PIP-467: Remove now-dead slf4j.api dependency from modules converted to slog [pulsar] via GitHub
  • Re: [PR] [improve] PIP-467: Remove now-dead slf4j.api dependency from modules converted to slog [pulsar] via GitHub
• [I] Add WARN log when cursor ack holes exceed managedLedgerMaxUnackedRangesToPersist [pulsar] via GitHub
  • Re: [I] Add WARN log when cursor ack holes exceed managedLedgerMaxUnackedRangesToPersist [pulsar] via GitHub
  • Re: [I] Add WARN log when cursor ack holes exceed managedLedgerMaxUnackedRangesToPersist [pulsar] via GitHub
• (pulsar-site) branch main updated: Add the release note for Python client 3.11.0 (#1116) xyz
• (pulsar-site) branch dependabot/npm_and_yarn/minimatch-3.1.5 deleted (was 2d56a231947) github-bot
• (pulsar-site) branch main updated: Bump minimatch from 3.1.2 to 3.1.5 (#1114) lhotari
• (pulsar-site) branch main updated: Docs: warn that negativeAcknowledge redelivery counter resets on dispatcher close (#1117) lhotari
• (pulsar) branch branch-4.2 updated: [fix][build][branch-4.2] Use correct Jetty ee8 BOM coordinates lhotari
• [I] [Bug][branch-4.2][build] Pulsar's maven build pulls in wrong Jetty ee8 pom as BOM, causing dependency issues [pulsar] via GitHub
  • Re: [I] [Bug][branch-4.2][build] Pulsar's maven build pulls in wrong Jetty ee8 pom as BOM, causing dependency issues [pulsar] via GitHub
  • Re: [I] [Bug][branch-4.2][build] Pulsar's maven build pulls in wrong Jetty ee8 pom as BOM, causing dependency issues [pulsar] via GitHub
• (pulsar) branch branch-3.0 updated (89d48c3b457 -> 03f298ef92d) lhotari
  • (pulsar) 03/03: [improve][ci] Backport fix for ssh-access action lhotari
  • (pulsar) 01/03: [improve][ci] Cleanup tune-runner-vm and clean-disk actions (#25444) lhotari
  • (pulsar) 02/03: [fix][ci] Fix .github/actions/ssh-access which is used for debugging Pulsar CI in forks (#25075) lhotari
• (pulsar) branch branch-4.0 updated (e4bbe0f2846 -> 65ec6af1663) lhotari
  • (pulsar) 01/02: [cleanup][ci] Remove ready-to-test label enforcement (#25470) lhotari
  • (pulsar) 02/02: [cleanup][ci] Remove documentation label bot (#25469) lhotari
• (pulsar) branch branch-3.0 updated: [cleanup][ci] Remove documentation label bot (#25469) lhotari
• (pulsar) branch branch-3.0 updated: [cleanup][ci] Remove ready-to-test label enforcement (#25470) lhotari
• (pulsar) branch branch-4.1 updated (29b1bcf7adf -> 0be605e7575) lhotari
  • (pulsar) 01/02: [cleanup][ci] Remove ready-to-test label enforcement (#25470) lhotari
  • (pulsar) 02/02: [cleanup][ci] Remove documentation label bot (#25469) lhotari
• (pulsar) branch branch-4.2 updated (ab397b1f086 -> 466dee1a898) lhotari
  • (pulsar) 02/02: [cleanup][ci] Remove documentation label bot (#25469) lhotari
  • (pulsar) 01/02: [cleanup][ci] Remove ready-to-test label enforcement (#25470) lhotari
• (pulsar) branch branch-4.0 updated: [fix][test][branch-4.0] Backport Pulsar IO Debezium connector test framework changes lhotari
• [PR] Docs: warn that negativeAcknowledge redelivery counter resets on dispatcher close [pulsar-site] via GitHub
  • Re: [PR] Docs: warn that negativeAcknowledge redelivery counter resets on dispatcher close [pulsar-site] via GitHub
• [PR] Add the release note for Python client 3.11.0 [pulsar-site] via GitHub
  • Re: [PR] Add the release note for Python client 3.11.0 [pulsar-site] via GitHub
• (pulsar-site) branch bewaremypower/release-python-3.11 created (now 48f68794fcc) xyz
  • (pulsar-site) 01/01: Add the release note for Python client 3.11.0 xyz
• [PR] Generate Python client 3.11.0 doc [pulsar-site] via GitHub
  • Re: [PR] Generate Python client 3.11.0 doc [pulsar-site] via GitHub
• (pulsar-site) branch py-docs-3.11 created (now 305e4087c3a) xyz
• (pulsar-client-python) annotated tag v3.11.0 updated (693e86d -> dbe6dc1) xyz
• [PR] Bumped version to 3.12.0a1 [pulsar-client-python] via GitHub
• svn commit: r83827 - dev/pulsar/pulsar-client-python-3.11.0-candidate-1 release/pulsar/pulsar-client-python-3.11.0 xyz
• [PR] [improve][client] Implement tls_client_auth for AuthenticationOAuth2 [pulsar] via GitHub
  • Re: [PR] [improve][client] Implement tls_client_auth for AuthenticationOAuth2 [pulsar] via GitHub
• (pulsar-site) branch dependabot/npm_and_yarn/minimatch-3.1.5 created (now 2d56a231947) github-bot
• [PR] Bump minimatch from 3.1.2 to 3.1.5 [pulsar-site] via GitHub
  • Re: [PR] Bump minimatch from 3.1.2 to 3.1.5 [pulsar-site] via GitHub
• (pulsar-site) branch dependabot/npm_and_yarn/dompurify-3.4.0 deleted (was 57ea1373fbb) github-bot
• (pulsar-site) branch main updated: Bump dompurify from 3.3.2 to 3.4.0 (#1113) lhotari
• (pulsar-site) branch dependabot/npm_and_yarn/dompurify-3.4.0 created (now 57ea1373fbb) github-bot
• [PR] Bump dompurify from 3.3.2 to 3.4.0 [pulsar-site] via GitHub
  • Re: [PR] Bump dompurify from 3.3.2 to 3.4.0 [pulsar-site] via GitHub
• [I] [Enhancement] Add client side looping to "pulsar-admin topics analyze-backlog" cli command [pulsar] via GitHub
• (pulsar) branch branch-4.0 updated: fix(client): remove stale securityutility import zhaocong
• (pulsar) branch branch-4.0 updated: fix(client): restore java 8 compatible key factory list zhaocong
• [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog [pulsar] via GitHub
• [PR] [improve] PIP-467: Convert pulsar-broker module logging from SLF4J to slog [pulsar] via GitHub
  • Re: [PR] [improve] PIP-467: Convert pulsar-broker module logging from SLF4J to slog [pulsar] via GitHub
• (pulsar) branch branch-4.2 updated: [fix][sec] Upgrade Jetty to address CVE-2026-5795 (#25532) lhotari
• (pulsar) branch master updated: [fix][sec] Upgrade Jetty to address CVE-2026-5795 (#25532) lhotari
• [PR] [fix][sec][branch-4.0] Upgrade to Jetty 12.1.8 to address several CVEs [pulsar] via GitHub
  • Re: [PR] [fix][sec][branch-4.0] Upgrade to Jetty 12.1.8 to address several CVEs [pulsar] via GitHub
• [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • Re: [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • Re: [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • Re: [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • Re: [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • Re: [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
  • Re: [PR] fix(asyncio): Avoid InvalidStateError on late callbacks after cancel [pulsar-client-python] via GitHub
• [I] Docs: warn that DeadLetterPolicy.maxRedeliverCount is silently unreliable with negativeAcknowledge under bundle unload / dispatcher close [pulsar] via GitHub
  • Re: [I] Docs: warn that DeadLetterPolicy.maxRedeliverCount is silently unreliable with negativeAcknowledge under bundle unload / dispatcher close [pulsar] via GitHub
  • Re: [I] Docs: warn that DeadLetterPolicy.maxRedeliverCount is silently unreliable with negativeAcknowledge under bundle unload / dispatcher close [pulsar] via GitHub
• (pulsar-connectors) branch master updated: [improve] Upgrade Hadoop to 3.5.0 (#18) lhotari
• (pulsar) branch branch-4.1 updated: [fix][build][branch-4.1] Fix missing exclusion in cherry-picking #25264 lhotari
• (pulsar) branch branch-4.1 updated (a9d866c7daf -> 990ac69414e) lhotari
  • (pulsar) 01/04: [fix][ci] Fix .github/actions/ssh-access which is used for debugging Pulsar CI in forks (#25075) lhotari
  • (pulsar) 04/04: [fix][ci] Ensure discard_max_bytes is set to 0 only for existing block devices (#25510) lhotari
  • (pulsar) 02/04: [improve][ci] Backport fix for ssh-access action lhotari
  • (pulsar) 03/04: [fix][ci] Disable trivy-action (#25373) lhotari
• (pulsar) branch branch-4.0 updated: [fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 mmerli
• (pulsar) branch branch-4.2 updated: [fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 mmerli
• (pulsar) branch branch-4.1 updated: [cleanup][build] Bumped version to 4.1.4-SNAPSHOT lhotari
• (pulsar) branch branch-4.0 updated (c5a05998424 -> 49343374aaa) lhotari
  • (pulsar) 02/04: [improve][ci] Backport fix for ssh-access action lhotari
  • (pulsar) 01/04: [fix][ci] Fix .github/actions/ssh-access which is used for debugging Pulsar CI in forks (#25075) lhotari
  • (pulsar) 04/04: [fix][ci] Ensure discard_max_bytes is set to 0 only for existing block devices (#25510) lhotari
  • (pulsar) 03/04: [fix][ci] Disable trivy-action (#25373) lhotari
• [PR] [fix][sec] Upgrade Jetty to address CVE-2026-5795 [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade Jetty to address CVE-2026-5795 [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade Jetty to address CVE-2026-5795 [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade Jetty to address CVE-2026-5795 [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade Jetty to address CVE-2026-5795 [pulsar] via GitHub
• (pulsar) branch branch-4.0 updated (fb5f211ee9b -> c5a05998424) lhotari
  • (pulsar) 01/11: [fix][build][branch-4.0] Fix broken compilation after cherry-picking #25400 lhotari
  • (pulsar) 10/11: [fix][build] Fix license file for shell distribution lhotari
  • (pulsar) 09/11: [fix][build][branch-4.0] Fix missing exclusion in cherry-picking #25264 lhotari
  • (pulsar) 06/11: [fix][broker] Return failed future instead of throwing exception in async methods (#25289) lhotari
  • (pulsar) 03/11: Revert "[fix][broker] Fix backlog clearing for unloaded namespace bundles (#25272)" lhotari
  • (pulsar) 08/11: [fix][broker] Fix backlog clearing for unloaded namespace bundles (#25272) lhotari
  • (pulsar) 04/11: [fix][admin] Refactor namespace anti affinity group sync operations to async in rest api (#25086) lhotari
  • (pulsar) 11/11: [cleanup][build] Bumped version to 4.0.10-SNAPSHOT lhotari
• [PR] [branch-4.0][fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 [pulsar] via GitHub
  • Re: [PR] [branch-4.0][fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 [pulsar] via GitHub
  • Re: [PR] [branch-4.0][fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 [pulsar] via GitHub
  • Re: [PR] [branch-4.0][fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 [pulsar] via GitHub
• (pulsar) branch branch-3.0 updated: [cleanup][build] Bumped version to 3.0.17-SNAPSHOT lhotari
• [PR] [branch-4.2][fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 [pulsar] via GitHub
  • Re: [PR] [branch-4.2][fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 [pulsar] via GitHub
• (pulsar) branch master updated: [fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 (#25521) mmerli
• (pulsar) branch branch-4.2 updated (2feaf26ae2b -> bd689be968d) lhotari
  • (pulsar) 05/05: [fix][ci] Ensure discard_max_bytes is set to 0 only for existing block devices (#25510) lhotari
  • (pulsar) 02/05: [fix][sec] Upgrade Jetty to address CVE-2026-2332 (#25527) lhotari
  • (pulsar) 04/05: [improve][ci] Backport fix for ssh-access action lhotari
  • (pulsar) 03/05: [cleanup][build] Bumped version to 4.2.1-SNAPSHOT lhotari
  • (pulsar) 01/05: [fix][broker] Revert "[improve][broker] Enhance advertised address resolution with fallback to localhost (#25238)" (#25523) lhotari
• [PR] [improve] Upgrade Hadoop to 3.5.0 [pulsar-connectors] via GitHub
  • Re: [PR] [improve] Upgrade Hadoop to 3.5.0 [pulsar-connectors] via GitHub
• (pulsar) branch master updated: [fix][sec] Upgrade Jetty to address CVE-2026-2332 (#25527) lhotari
• (pulsar) branch master updated: [fix][broker] Revert "[improve][broker] Enhance advertised address resolution with fallback to localhost (#25238)" (#25523) zixuan
• (pulsar) branch branch-4.1 updated (30578f8cd06 -> 62fbef788f2) lhotari
  • (pulsar) 01/02: [improve][ci] Cleanup tune-runner-vm and clean-disk actions (#25444) lhotari
  • (pulsar) 02/02: [fix][broker] Change the schema incompatible log from ERROR to WARN level (#25483) lhotari
• [PR] [fix][broker] Avoid Project access in broker test setup [pulsar] via GitHub
  • Re: [PR] [fix][broker] Avoid Project access in broker test setup [pulsar] via GitHub
• [PR] [fix][broker] Defer ack state updates until persistence succeeds [pulsar] via GitHub
  • Re: [PR] [fix][broker] Defer ack state updates until persistence succeeds [pulsar] via GitHub
  • Re: [PR] [fix][broker] Defer ack state updates until persistence succeeds [pulsar] via GitHub
• (pulsar) branch branch-4.1 updated (e11ff901679 -> 30578f8cd06) lhotari
  • (pulsar) 02/02: [improve][build][branch-4.1] Support docker.golang.image/GOLANG_IMAGE in latest-version-image lhotari
• (pulsar) branch branch-4.0 updated: [improve][build][branch-4.0] Support docker.golang.image/GOLANG_IMAGE in latest-version-image lhotari
• (pulsar) branch branch-4.2 updated (de347884acb -> 2feaf26ae2b) lhotari
  • (pulsar) 07/07: [improve][broker] Close connection when close consumer write fails (#25520) lhotari
  • (pulsar) 05/07: [fix][broker] Change the schema incompatible log from ERROR to WARN level (#25483) lhotari
  • (pulsar) 01/07: [fix][sec] Upgrade to Netty 4.1.132.Final to address CVEs (#25399) lhotari
  • (pulsar) 03/07: [improve][ci] Cleanup tune-runner-vm and clean-disk actions (#25444) lhotari
  • (pulsar) 02/07: [fix][client] Fix thread-safety and refactor MessageCryptoBc key management (#25400) lhotari
  • (pulsar) 06/07: [fix] Upgrade Jetty to 12.1.6 to fix CVE-2026-1605 (#25485) lhotari
• [PR] [fix][sec] Upgrade Jetty to address CVE-2026-2332 [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade Jetty to address CVE-2026-2332 [pulsar] via GitHub
  • Re: [PR] [fix][sec] Upgrade Jetty to address CVE-2026-2332 [pulsar] via GitHub
• (pulsar) branch branch-4.0 updated (3d33e4874fe -> 465af5cf8b4) zhaocong
• (pulsar-site) branch main updated: Add go client release notes for 0.19.0 (#1112) zike
• [PR] Add go client release notes for 0.19.0 [pulsar-site] via GitHub
  • Re: [PR] Add go client release notes for 0.19.0 [pulsar-site] via GitHub
• (pulsar-site) branch go-0.19.0-release-note created (now a12df323af7) zike
  • (pulsar-site) 01/01: Add go client release notes for 0.19.0 zike
• svn commit: r83801 - dev/pulsar/pulsar-client-go-0.19.0-candidate-1 release/pulsar/pulsar-client-go-0.19.0 zike
• (pulsar-client-go) branch master updated: Add release note for 0.19.0 (#1475) xyz
• (pulsar-client-go) branch master updated: fix(test): add localhost advertised address to standalone startup (#1480) zike
• (pulsar) branch master updated: [fix] Fix typo 'seperated' in broker comments (#25524) zixuan
• [PR] [ci] Branch 4.0 [pulsar] via GitHub
  • Re: [PR] [improve][ci] Branch 4.0 [pulsar] via GitHub
  • Re: [PR] [improve][ci] Branch 4.0 [pulsar] via GitHub
• (pulsar-client-cpp) branch main updated: [fix][cpp-client] Pass seek error to callback when SEEK command fails (#549) xyz
• [PR] [improve][client] Best-effort retry for acks on send failure when ackReceiptEnabled=false [pulsar] via GitHub
• [I] partitionConsumer reconnectToBroker reaches max retry but no notification/closure to external user [pulsar-client-go] via GitHub
• [PR] [fix] Fix typo 'seperated' in broker comments [pulsar] via GitHub
  • Re: [PR] [fix] Fix typo 'seperated' in broker comments [pulsar] via GitHub
• (pulsar) branch master updated: [fix][broker] Unthrottle producers immediately when publish rate limiting is disabled (#25502) thetumbled
• (pulsar) branch master updated: [improve] Add PULSAR_LOG_FORMAT env var for easy JSON logging (#25515) mmerli
• [PR] [fix][broker] Revert "[improve][broker] Enhance advertised address resolution with fallback to localhost (#25238)" [pulsar] via GitHub
  • Re: [PR] [fix][broker] Revert "[improve][broker] Enhance advertised address resolution with fallback to localhost (#25238)" [pulsar] via GitHub
• (pulsar) branch master updated: [improve][broker] Close connection when close consumer write fails (#25520) zixuan

• Earlier messages