Samuel Cantero

icon indicating an email [email protected]

icon location Paraguay

Results 25 comments of Samuel Cantero

Error propagation differences between the callback and event API

By looking at the code, it looks like we build RD_KAFKA_OP_CONSUMER_ERR errors (i.e errors that are returned to the app) by calling [rd_kafka_consumer_err](https://github.com/confluentinc/librdkafka/blob/v2.3.0/src/rdkafka_op.c#L519-L532). Then by looking at where this is...

Fix StreamConsumer wakeup races

Nice finding @trtt! This looks correct to me but if @duarten, @davidblewett and @fede1024 could also give it another look would be great.

stop logging errors on replicas, fixes #547

thanks! are you planning a new release soon?

OffsetCommitRequest timeout causes consumers rebalancing

Hi @edenhill! We're also hitting this issue. In this case it looks like HOLB but I don't have metrics/log on the consumer side to confirm this. We enabled `"debug":"protocol"` but...

fix #547

What are we missing to get this merged?