Xiangying Meng

Master Issue: https://github.com/apache/pulsar/issues/16913 ### Motivation Implement an abortedTxnProcessor to handle the storage of the aborted transaction ID. ### Modifications The structure overview:  The main idea is to move the...

[fix][broker] Create new ledger after the current ledger is closed

11

### Motivation #### Background 1. Managerledger has a configuration `maximumRolloverTimeMs` to configure the max time of closing a ledger. 2. The current ledger can be rollover when it reaches `maximumRolloverTimeMs`....

[branch-2.10][improve][broker] Do not retain the data in the system topic

1

### Motivation For some use case, the users need to store all the messages even though these message are acked by all subscription. So they set the retention policy of...

### Motivation The time value should not be a negative value. We need to add a check when get a time value input. ### Modifications Add a check when get...

[bug] Go and Java Schema Incompatibility in Pulsar

1

### Description The issue highlights the incompatibility between Go and Java schemas in Pulsar, specifically focusing on Avro, JSON, Proto, and ProtoNative schemas. #### Avro Schema Avro schema is compatible...

[feature request] Support Transaction API

1

### Motivation Now, the pulsar-client-go does not support the go-client, so I want to support transaction API for the go client. ### Solution Add Transaction API for go client.

[fix][client] the nullValue in msgMetadata should be true by default

1

### Motivation When a message is not set value, the `nullValue` message metadata should be true and change to false after the value is set. Otherwise, the message data will...

[improve][txn] Take first snapshot before persisting the first transactional message

4

### Motivation The decision to write a snapshot before the first transaction message instead of before building the producer, is based on the fact that only the act of writing...

[improve][pip] PIP-367: Propose a Contributor Repository for Pulsar

4

### Motivation See proposal for detail. ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)* This...