Marvin Cai

@dlg99 according this code snippet, the DeatchWather should be able to catch the case and shut down the whole autorecovery right? https://github.com/apache/bookkeeper/blob/master/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AutoRecoveryMain.java#L213-L240 ``` setUncaughtExceptionHandler((thread, cause) -> { LOG.info("AutoRecoveryDeathWatcher exited loop...

`bin/pulsar initialize-cluster-metadata` looks like the command to initialize cluster metadata for Pulsar cluster. As in `bin/pulsar` script ipv6 support is explicitly disabled: https://github.com/apache/pulsar/blob/3f109d6cb7f128a5f8331e33477fd69c3c26d531/bin/pulsar#L275 But we can override it by using...

shall we also remove all manifests related to this?

seems we're defining duplicated key, can we do: ``` {{- if .Values.broker.imagePullSecrets }} imagePullSecrets: - name: {{ .Values.broker.imagePullSecrets }} {{- else }} {{- if .Values.imagePullSecrets }} imagePullSecrets: - name: {{...

Does this happen in real world scenario? even if a chunk message take all remaining send permits, sending for earlier messages will be completed and release permits, unless one big...

Hi, thanks for replying, I was cloning this repo and trying to build it: https://github.com/wyyerd/pulsar-rs

@eolivelli Yes, we could, but that's gonna the default behavior, which might break any existing users' operation that depends on this default behavior(even it's not the desired behavior), also if...

the doc for `Consumer#pause` is ``` /** * Stop requesting new messages from the broker until {@link #resume()} is called. Note that this might cause * {@link #receive()} to block...

@xuesongxs have you checked with `pulsar-admin topics stats ` or `bookkeeper shell ledger ` to make sure entries do exist in BookKeeper? If not filtering by __publish_time__ then default behavior...