Penghui Li comments

Results 151 comments of


                                            Penghui Li

[fix][txn]Make txn metrics name conforms to the rule

/pulsarbot run-failure-checks

[fix][broker]fix Repeated messages of shared dispatcher

@poorbarcode Interesting. I think the expected behavior is no matter how many consumers are under a subscription. The subscription should only perform the entry read operation one by one.

InflightReadsLimiter - limit the memory used by reads end-to-end (from storage/cache to the write to the consumer channel)

> Broker can go out of memory due to many reads enqueued on the PersistentDispatcherMultipleConsumers dispatchMessagesThread @eolivelli Does it only happen when the broker has many subscriptions? For one subscription,...

InflightReadsLimiter - limit the memory used by reads end-to-end (from storage/cache to the write to the consumer channel)

/pulsarbot run-failure-checks

[improve][broker] do not grant permission for each partition to reduce unnecessary zk metadata

@TakaHiR07 It's better to have a discussion on the dev mailing list. We will change the behavior of the current implementation. Just make sure everyone is clear about what we...

[fix][broker][branch-2.11] fix delete_when_subscriptions_caught_up doesn't work while have active consumers

/pulsarbot run-failure-checks

PIP-221: Make TableView support read the non-persistent topic

@Demogorgon314 It's a little confusing if the TTL can only apply to the table view that is based on the non-persistent topic. Or can it also apply to the persistent...

PIP-221: Make TableView support read the non-persistent topic

@Demogorgon314 LGTM

[Bug] TransactionCoordinatorClientImpl.start() hangs forever

@congbobo184 I think we should provide clear information while the transaction coordinator does not enable it on the broker side. It will help users to understand the problem quickly.

PIP-220: TransferShedder

I think the part of `More aggressive load balance strategy` mentioned in this proposal is resolved by https://github.com/apache/pulsar/pull/17456 For the load balance epochs. I'm not if I understand it correctly....