pulsar

pulsar copied to clipboard

[Bug] Peek nth message REST API returns incorrect data

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

gaecfov

[improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability

2

Main Issue: #23205 ### Motivation Currently there aren't ways to observe the number of messages that are "in replay" with Key_Shared or Shared subscriptions. Having these metrics would make it...

lhotari

[BUG] Custom Java Sink Connector: Logging statement in 'close' method not executed on deletion or stop

4

When adding a logging statement inside the "close" method of a custom sink connector, uploading it to a standalone cluster, and then deleting or stopping the connector, the logging statement...

NurramoX

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

MagicalFool

[Bug] Key_Shared subscription could deliver messages late and nonContiguousDeletedMessagesRange could exceed managedLedgerMaxUnackedRangesToPersist

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsupported versions don't get bug fixes....

lhotari

Replace the ConcurrentOpenHashMap as much as possible

6

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation There was a discussion at Sep. 2023 before to replace Customized Map with...

BewareMyPower

[improve][client]Reduce CPU usage when client idle and batch message enable

8

Reduce CPU usage when client idle and batch message enable Fixes #23187 ### Motivation ProducerImple use EventLoopGroup to send batch message per 1ms by default, it would cause about 14%...

stillerrr

[feat] Use producer name and sequence number as fallback key in Key_Shared implementation

2

Fixes #23212 ### Motivation Taken from issue: The Key_Shared implementation expects that the incoming message contain either a key/keyBytes or orderingKey. If the key isn't set, the implementation will use...

pdolif

Fixes [#23161](https://github.com/apache/pulsar/issues/23161) Main Issue: #xyz ### Motivation java.lang.AssertionError: expected [5] but found [6] at org.testng.Assert.fail(Assert.java:110) at org.testng.Assert.failNotEquals(Assert.java:1577) at org.testng.Assert.assertEqualsImpl(Assert.java:149) at org.testng.Assert.assertEquals(Assert.java:131) at org.testng.Assert.assertEquals(Assert.java:1418) at org.testng.Assert.assertEquals(Assert.java:1382) at org.testng.Assert.assertEquals(Assert.java:1428) at org.apache.pulsar.broker.service.CurrentLedgerRolloverIfFullTest.testCurrentLedgerRolloverIfFull(CurrentLedgerRolloverIfFullTest.java:84) at...

marekczajkowski

[feat] Replace the default NONE_KEY in Key_Shared implementation with producer name and producer sequence number

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation The Key_Shared implementation expects that the incoming message contain either a key/keyBytes or...

lhotari