pulsar

pulsar copied to clipboard

[Feature][Txn] Support for commit idempotency.

3

PIP: https://github.com/apache/pulsar/issues/19744 ### Motivation - Message queues such as Kafka and Pulsar can only guarantee the exactly-once semantics provided by the transaction feature under **the specific use scenario of `consume-transform-produce`...

thetumbled

Pulsar topic auto deletion not work

5

### 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....

river1017

[improve][broker] Optimize PersistentTopic.getLastDispatchablePosition

1

### Motivation [PersistentTopic#getLastDispatchablePosition](https://github.com/apache/pulsar/blob/master/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java#L3776-L3788) is using by [Reader#hasMessageAvailable](https://github.com/apache/pulsar/blob/master/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Reader.java#L116) , [ConsumerImpl#hasMessageAvailable](https://github.com/apache/pulsar/blob/master/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java#L2440-L2448), [Consumer#getLastMessageIdAsync](https://github.com/apache/pulsar/blob/master/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Consumer.java#L591-L615). The current implementation is read entries from Bookkeeper(or sth else), which leads to low throughput, high latency and heavy load,...

dao-jun

[Fix][broker] Limit replication rate based on bytes

2

### Motivation When the replicator rate limit value based on bytes is less than the `org.apache.pulsar.broker.service.persistent.PersistentReplicator#readMaxSizeBytes`, this will cause the outgoing bytes to exceed the limit value. The goal is...

nodece

[improve][pip] PIP-352: Event time based topic compactor

6

PIP: 352 ### Motivation Currently, there are two types of compactors available: `TwoPhaseCompactor` and `StrategicTwoPhaseCompactor`. The latter is specifically utilized for internal load balancing purposes and is not employed for...

marekczajkowski

[Bug] consumers stops receiving new messages due to invalid blockedConsumerOnUnackedMsgs state

22

### 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....

180254

Brokers are not able to load topics in non-recoverable situation

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation We have introduced a configuration called “autoSkipNonRecoverableData” before open-sourcing Pulsar as we have...

rdhabalia

[improve][broker] PIP-327: Support force topic loading for unrecoverable errors

2

It fixes https://github.com/apache/pulsar/issues/21751 PIP: #21752 ### Motivation We have introduced a configuration called `autoSkipNonRecoverableData` before open-sourcing Pulsar as we have come across with various situations when it was not possible...

rdhabalia

### Motivation [PIP-229](https://github.com/apache/pulsar/pull/19414) introduces an interface change for the messageId which break the behavior in and after Pulsar 3.0. This leads to the `MessageIdUtils` not be able to handle the...

RobertIndie

[Bug] Deadlock in broker service while initializing bkClient

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....

Meet0861