Thomas David Dickinson

Presuming you are referring to the kubernetes liveness probe (readiness probe is another matter.) What we do: - just simply return a 200 on the liveness route. This in itself...

Switch default producer partitioner to ```JavaCompatiblePartitioner```. https://github.com/tulios/kafkajs/pull/358 I realise that changing this has issues as it would cause problems for users that upgrade kafkajs version for their current apps. But...

There is a all settled() implementation in /utils. On Thu, 10 Mar 2022, 23:09 Carlos Jiménez Saiz, ***@***.***> wrote: > As extended error classes are currently be using in the...

@Nevon I re-worked this. The change is bigger but I think it makes the code more readable. As @Nevon suggested, we explicitly use a AggregateError for fetch. 1 change since...

@boblauer I tried and failed to reproduce this, on master and on 1.14.0. I added below at examples/consumer.js line 57: ``` await consumer.stop() await consumer.disconnect() ``` and ran the example....

Looking at the code, the retry mechanism isn't halted when the producer (and cluster) are disconnected, so it will always run to completion. I would say this is a bug....

If the logs above are complete, it seems there is a missing end_batch_process event for partition 9. Which suggests the batch processing has hung. Do you have any logging in...

> Is not resolving the handler a viable solution? You would need to make sure that heartbeats continued to be sent, otherwise you'll hit the sessionTimeout. You'll need to use...

@521707 I don't have time to look at this in detail. But first thing I would try is to not call consumer.commitOffsets() from with your eachMessage() function - I'm not...

@assaf-xm I think you should wait on this until we know what's happening with https://github.com/tulios/kafkajs/pull/667 .