Milind L

> Can you confirm that `await producer.send({...})` will throw an error if message/batch is not received per the `acks` value, as in KafkaJS? Regarding this, yes, you will get a...

Regarding your second message, there are two things, 1. The consumer performance 1 second jumps. I'd written an optimization to get rid of those, I'd just turned it off by...

Regarding the second question above. The main culprit - the producer takes a longer time to send the _first_ message to a topic. This is because there is no metadata...

I understand the requirement, but at the same time, we avoid caching metadata for all topics initially, because it incurs a penalty for memory (small), and for subsequent metadata requests...

It isn't accessible yet, but I discussed this within the team and we finalized an approach. There's a non-trivial code change required internally to make it accessible, I'll keep this...

Thanks for filing this issue. Can you tell me more about the size of the data: `The size of the data to be produced is around 1-3million` -> This is...

Hey - while I don't think there is a plan to immediately add this enhancement right now, I can suggest a better workaround. You can use the `Subscription()` method to...

I think the API is worth considering, but there are several things which means it will probably not be prioritized soon. This is a public API, once we support it,...

Hi @schmigware , thanks for filing this issue. One question, does it happen every time, or does this happen intermittently? Your statement makes it seem that each consumer from this...

Hi @ylhan , Is there a goroutine or something that is reading from the producer.Events() channel? That channel needs to be read from continuously, as there might be some administrative/control...