Skip to content

Conversation

@Technoboy-
Copy link
Contributor

Motivation

When create the consumer/reader with the same sub name, the broker will print the error log as below, to avoid printing the noise log, change the log from ERROR to INFO

2026-01-07T15:39:16,075+0000 [ForkJoinPool.commonPool-worker-2] INFO  org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/default/test-staging-partition-0][test-consumer-1014-9873] Creating non-durable subscription at msg id 1014:37462:0:2 - {}
2026-01-07T15:39:16,075+0000 [ForkJoinPool.commonPool-worker-2] ERROR org.apache.pulsar.broker.service.persistent.PersistentTopic - [persistent://public/default/test-staging-partition-0] Failed to create subscription: test-consumer-1014-9873
java.util.concurrent.CompletionException: org.apache.pulsar.broker.service.BrokerServiceException$NotAllowedException: Durable subscription with the same name already exists.
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.thenCompose(Unknown Source) ~[?:?]
	at org.apache.pulsar.broker.service.persistent.PersistentTopic.lambda$internalSubscribe$25(PersistentTopic.java:1022) ~[io.streamnative-pulsar-broker-4.1.0.7.jar:4.1.0.7]
	at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.thenCompose(Unknown Source) ~[?:?]

Documentation

  • doc
  • doc-required
  • doc-not-needed
  • doc-complete

@Technoboy- Technoboy- self-assigned this Jan 8, 2026
@Technoboy- Technoboy- added this to the 4.2.0 milestone Jan 8, 2026
@github-actions github-actions bot added the doc-not-needed Your PR changes do not impact docs label Jan 8, 2026
@Technoboy- Technoboy- changed the title [improve][broker] Change the log level from error to info when the cursor exists. [improve][broker] Change the log level from error to info when the cursor exists or throwing NotAllowedException Jan 8, 2026
@Technoboy- Technoboy- changed the title [improve][broker] Change the log level from error to info when the cursor exists or throwing NotAllowedException [improve][broker] Change the log level from error to info when throwing NotAllowedException Jan 8, 2026
@codecov-commenter
Copy link

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 74.45%. Comparing base (40953cb) to head (1fc86a6).

Additional details and impacted files

Impacted file tree graph

@@              Coverage Diff              @@
##             master   #25130       +/-   ##
=============================================
+ Coverage     38.60%   74.45%   +35.85%     
- Complexity    13136    34045    +20909     
=============================================
  Files          1842     1899       +57     
  Lines        145550   149716     +4166     
  Branches      16919    17406      +487     
=============================================
+ Hits          56183   111473    +55290     
+ Misses        81663    29356    -52307     
- Partials       7704     8887     +1183     
Flag Coverage Δ
inttests 26.29% <0.00%> (-0.24%) ⬇️
systests 23.03% <0.00%> (+<0.01%) ⬆️
unittests 73.99% <100.00%> (+39.63%) ⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Files with missing lines Coverage Δ
...sar/broker/service/persistent/PersistentTopic.java 80.23% <100.00%> (+30.43%) ⬆️

... and 1404 files with indirect coverage changes

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.
  • 📦 JS Bundle Analysis: Save yourself from yourself by tracking and limiting bundle sizes in JS merges.

@Technoboy- Technoboy- merged commit d72dc04 into apache:master Jan 8, 2026
56 of 57 checks passed
Technoboy- added a commit that referenced this pull request Jan 8, 2026
Technoboy- added a commit that referenced this pull request Jan 8, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants