Lari Hotari

icon company @StreamNative icon location Espoo, Finland icon location OSS contributor. Distributed Systems Engineer. Apache Pulsar PMC member. Apache Software Foundation member. Sr. Technologist, Office of CTO @ StreamNative

Results 996 comments of Lari Hotari

[feat] Add topic stats and metrics for observing message replay behavior and Key_Shared filtering/blocking behavior

#23224 implemented `msgInReplay` / `pulsar_subscription_in_replay`.

[feat] Add topic stats and metrics for observing message replay behavior and Key_Shared filtering/blocking behavior

#23429 adds observability for PIP-379 Key_Shared implementation. `drainingHashesCount`, `drainingHashesClearedTotal`, `drainingHashesUnackedMessages` and `drainingHashes`

[feat] Add topic stats and metrics for observing message replay behavior and Key_Shared filtering/blocking behavior

Closing this as resolved with #23224 and #23429 in PIP-379 implementation.

Flaky-test: SimpleProducerConsumerTest.testMultiTopicsConsumerImplPauseForManualSubscription

> I would like to share my findings about the test case. It tests the pausing of a multi-topic consumer by doing the following Very good analysis @pdolif ! One...

[fix] retry producer creation upon error after succssful topic lookup

Great work @zzzming! I'll review again after you reply to the question.

[Bug] Multi-role does not forbid user if proxy superuser

> I have done the test with one role in the client token, so I expect the same behavior with the 2 authorization providers `org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider` and `org.apache.pulsar.broker.authorization.MultiRolesTokenAuthorizationProvider` this seems to...

Any idea when next release might come up?

I guess we can start a new release asap if the current master branch is ready for releasing. I don't currently have time to verify, but I believe I could...

Pulsar Manager: ERROR: relation "environments" does not exist

> its fixed by adding: > > ``` > SPRING_CONFIGURATION_FILE: "/pulsar-manager/pulsar-manager/application.properties" > ``` > > to configData > > I wonder why that is not on per default? @Mortom123 Would...

[improve][broker] Replace all ConcurrentOpenHashMap with the official ConcurrentHashMap in JDK

Closing since the changes have been made in other PRs.

[Bug] [Regression] etcd mTLS doesn't work on 3.3.1

> java.lang.NoSuchMethodError because of this PR: https://github.com/apache/pulsar/pull/22892 @martin31821 Please share the full exception stack trace.