pulsar

pulsar copied to clipboard

Reset partitions of a topic

4

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation There is a API for increase partitions for a topic https://pulsar.apache.org/admin-rest-api/?version=3.3.0#operation/PersistentTopics_updatePartitionedTopic but it...

fecet

[Bug] [broker]Sometime after reset cursor, unable to reconsume all messages in topic when ttl is less than retention time.

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

hanmz

[improve][broker] Enhance broker metrics to support URL parameter filtering

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation The motivation for enhancing broker metrics to support URL parameter filtering in Pulsar...

zwOvO

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

hanmz

[fix][broker] Broker incorrectly validates proxy role for http request

10

### Motivation When Proxy and appropriate Proxy authentication is introduced in the Broker, the Proxy first authenticates the request coming from the client and retrieves its principal name, and passes...

rdhabalia

Kafka Sink Connector: support non-String keys

3

Currently the Kafka Sink Connector is able to support only keys with a String value. We should support the generic byte[] key, as it is in Kafka. Also we should...

eolivelli

[Transaction] One single TC unavailable cause transactional throughput down to 0.

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Transaction module introduce multiple(default 16) TC to improve performance. However, if part of...

thetumbled

Main Issue: https://github.com/apache/pulsar/issues/23022 ### Motivation As shown in the issue. Fix occur confusing error log when use reader to read entry. ### Modifications In the case that read entry failed...

TakaHiR07

[PIP-264](https://github.com/apache/pulsar/blob/master/pip/pip-264.md) ### Motivation Adds replicated subscription metrics, defined [here](https://github.com/apache/pulsar/blob/c160cc9c3d44c1df073d63b325b45b9bc9bff8c7/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java#L73) and [here](https://github.com/apache/pulsar/blob/c160cc9c3d44c1df073d63b325b45b9bc9bff8c7/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsSnapshotBuilder.java#L55), to the OpenTelemetry pipeline. ### Modifications - Added metrics, as described by https://github.com/apache/pulsar-site/pull/941, to the OpenTelemetry pipeline. Since these...

dragosvictor

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation As the code shown, even if we disable txn, we use topic.getMaxReadPosition() which...

TakaHiR07