Ehud Lev

Hi,  First of all, thanks for this great library. We are using Reactor since we are writing to S3 and RDS and we want to do it in an async...

PR is too much for me now, Our code is written in kotlin and obviously I can not share it, but I converted the relevant parts to java. For what...

Hi again, Following adding a PR to contribute to the project, I tried to download and compile it locally, and it failed, the reason it fails as far as I...

Hi, thank you for your response, We did get this issue again, when it happened we saw many warning logs that looked like the following: `Warning: 1 records in the...

Yes, I am printing everything I can (error-info), I also trying to catch all exceptions and send records that has failed into different DLQs. I am printing the `record.numberOfFailedAttempt` but...

I don't have the historical information, I can say that now ( 1.5 hours after the restart) it is CURRENT-OFFSET LOG-END-OFFSET LAG 54203593 54203720 127 Must say that this does...

Looks like we can benefit a lot from this PR as is. As for other metrics, I am not sure if it makes sense, but I can think those: 1....

Hi @rkolesnev can you elaborate how can I "keep current batch size and add linger (i.e. timeout for waiting to fill the batch)" I thought linger is only in the...

Hi @rkolesnev, As for a, yes it is best effort, similar to some behavior of kafka connect using `partition.duration.ms` if I remember correctly.   As for b, It is only relevant...