Samuel Cantero
Samuel Cantero
We tested internally today the `BaseProducer` and `BaseConsumer` and we couldn't reproduce the issue. We'll try out tomorrow the `FutureProducer` and the `StreamConsumer`. Please provide the properties you're setting and...
I'm surprised we're seeing a working case of the producer with @zhrebicek and a non working one with @neoeinstein. I wonder what the differences would be here. @zhrebicek I see...
@zhrebicek yeah that translates to stopping the stream entirely when an error is encountered. If a kafka cluster is under high load, then most likely you'll have a lot of...
@zhrebicek I see. We haven't able to reproduce this so far. We have tests running for over 5 days and we have tried several operations on the cluster (rolling restarts,...
@zhrebicek no worries! Totally get that. what RF are you using and what kafka version?
@zhrebicek would it be possible to run a shadow service (that send all reads to dev/null) with this version and debug level enabled (same for rdkafka logs) on the environment...
Thanks @zhrebicek ! appreciate that
Hi @maleadt! Thanks for reporting this. I took a look and I've found that _rss_ stat inside _memory.stat_ always matches **usage_in_bytes - cache**. In case this is correct, we might...
is there any ongoing work for this?
@emasab I know guys this is not a high priority for you, but is there any way where I can easily get the list of transient errors (assuming this is...