Abhishek Agarwal

Can you describe the authorization flow that uses these attributes? There are also compilation failures in your code.

I guess it's not possible to add one. It's best to remove the one you added as that one doesn't look useful.

You can refer to the javadocs of these interfaces to get an idea behind these classes. AggregatorFactory is what you use to get a off-heap aggregator or an on-heap aggregator...

How will this design work when there are used segments but have zero replication factor?

It was indeed simpler to extend the single supervisor to read from multiple topics in the same cluster. You also get the benefit of auto-discovering new topics against a regex...

I wasn't imagining that composite supervisor itself has multiple supervisors. Its just a separate supervisor that directly manages various kafka tasks that could be consuming data from different clusters. I...

Go ahead please On Fri, 15 Mar 2024 at 2:29 AM, AlbericByte ***@***.***> wrote: > @abhishekagarwal87 and @cryptoe > may i continue to work on this, seems there > is...

So there are two paths that get impacted Query path - when the processing on pod stops abruptly, do the queries for this pod fail or do they get stuck?...

When you open the console in the browser, can you look at the network tab in "Developer Tools" (assuming Chrome)? Through that, you can get the exact HTTP request that's...

Feel free to pick it up. Let us know when you need help with review