Elliot West

> > Looking into it a bit when running on Spark EMR for instance I believe there is ongoing work to have the HiveMetaStoreClientFactory abstraction contributed to vanilla Apache Hive:...

@nodece I had a go at this here #784, however I'm quite new with Go and `pulsarctl` so you may wish to approach the issue in a different way.

Is the root of the problem here that the character sequences in question are not being properly encoded when forming the admin URLs? From the example given, I am seeing...

Thanks for pointing these out @bygui86 — it'd be great to have more systems represented and contributed.

Can we extract an interface: ```java interface ThroughputOptimizer { long nextProducerTargetRate( long observationTimeStamp, BenchmarkPhase benchmarkPhase, long currentProducerRate, long currentConsumerRate, long currentBacklogSize, long currentProducerDelay ); } enum BenchmarkPhase { WARM_UP, BACKLOG_FILL,...

I've been trying this out. It behaves well IMO, and was able to attain optimal rates very close to those that I've located by hand. I suggest moving from draft...

I believe it is. I’ve been using it. On Thu, 20 Oct 2022 at 06:26, Matteo Merli ***@***.***> wrote: > @nahguam Is it good to go for you? > >...

Did this get raised with the Pulsar client lib project?

Hey @cricket007. Yes, this is a familiar problem domain for me (regrettably). We'd previously solved this by building around the ground up services that focused **only** on landing data to...

> I want to ask about the definition of "finalized partitions". This makes sense in the context of the wall clock partitioner, but not others. Our Hive ETL consumers are...