Oneby

关于【Redis 哨兵集群实现高可用】的问题

1

不懂就问，在【哨兵的核心知识】章节，4 个哨兵，majority 不应该是 3 吗？ 

**Describe the bug**: Hi, I think that I found a little bug in mop authorization module. Pulsar version: 3.0.5 MoP version: 3.0.5.8 Configuration: in mop, when I set the authorization...

[fix][admin] Refactor bookie affinity group sync operations to async in rest api

1

### Motivation It is not recommended to use sync operations in NIO threads, which would block other operations and degrade the overall performance of the system. ### Modifications Refactor bookie...

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

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

[fix][broker] Fix replicator producers can not share with other exclusive producers

1

Fixes https://github.com/apache/pulsar/issues/24914 ### Motivation Fix geo replication doesn't support normal exclusive producers. ### Modifications Modify AbstractTopic#incrementTopicEpochIfNeeded() method to support normal exclusive producers can share with replicator producers. ### Verifying this...

Fix mqtt disconnect due to appId permission bug when namespace policies update

1

### Motivation MQTTConsumer appId field is equivalent to the userRole in Authentication. The appId field will be used to do checkPermissionsAsync when namespace policies update. https://github.com/apache/pulsar/blob/0a949de4bfa3734194be87a8655763a4411be1b6/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java#L1042-L1044 ### Modifications Before: appId...

[improve][server]Add entry digest in journal log file

1

Hi, I recently read BookKeeper journal source code, and I found that BookKeeper journal didn't use any digest to guarante journal data's integrity and consistency. https://github.com/apache/bookkeeper/blob/2789316c18e12cbb6d17fa4a023410dbad6593a0/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java#L811-L885 Due to the lack...

Hi, I recently read BookKeeper GC source code to figure out what situation will cause data loss in pull request [Fix the data loss issue that caused by the wrong...