pulsar

pulsar copied to clipboard

### Motivation In previous code, we use `client.getConfiguration().getProperty(ClientProperties.CONNECT_TIMEOUT)` as PulsarAdmin's `connectionTimeoutMs`, use `client.getConfiguration().getProperty(ClientProperties.READ_TIMEOUT)` as PulsarAdmin's `readTimeoutMs`, use `PulsarAdminImpl.DEFAULT_REQUEST_TIMEOUT_SECONDS * 1000` as PulsarAdmin's `requestTimeoutMs`. See: https://github.com/apache/pulsar/blob/b71bea4c42353f9d14f817aa9a0877d495336f34/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java#L121-L128 Before this PR, we can't...

oneby-wang

[fix][broker] Fix partitioned topic auto deletion http request timeout

3

Fixes https://github.com/apache/pulsar/issues/24879 ### Motivation Partitioned-topic auto deletion call chain: 1. gc process(invoked on broker0) 2. delete partitioned-topic admin api(invoked on broker0) 3. delete topic-partition-0 admin api(invoked on broker0) If brokerClient's...

oneby-wang

[improve][pip] PIP-449: Improve metadata sync to have exclusions in syncing specific config matching regex pattern across onprem and cloud clusters

3

### Motivation The pulsar metadata sync does not have a way to exclude specific config from syncing across clusters. For example, a cluster need to have a separate config in...

vraulji567

[Bug] update partition process is not reasonable since branch-3.0

2

### Search before reporting - [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](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

TakaHiR07

[Bug] Update netty allocator options to avoid oom when using EntryFilters

7

### Search before reporting - [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](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

geniusjoe

[Bug] Topic list watcher will miss changes while metadata store connection is disconnected

1

### Search before reporting - [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](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

lhotari

[Bug][io] JdbcSink: potential memory leak/OOM due to lack of backpressure in internal buffering

2

### Search before reporting - [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](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

peterh-wob

[improve][jdbc] Add time handling support

2

Main Issue: https://github.com/apache/pulsar/discussions/23109 ### Motivation * This PR adds abstract support for JDBC sink to enable datetime inserts into databases ### Modifications * Added a protected method on the base...

omrifried

[improve][broker] PIP-433: Ensure topic creation before starting GEO

1

PIP: #24485 ### Motivation In a GEO replication scenario, if the remote cluster does not have the replicated topic and the auto-creation type differs between the local and remote clusters,...

nodece

[Enhancement] Future optimization and defect fixing of the delayed message module

2

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation ## Future **Currently, I am deeply researching the delayed message module of Pulsar...

Denovo1998