Rob Hansen
Rob Hansen
Thanks for the additional insight @kikyomits. It also appears there's a bug in the v2 iam package integration https://github.com/segmentio/kafka-go/issues/976 The error messages appear different but could also be related.
@mtkopone Are you still seeing this issue if you use the tip of main? With https://github.com/segmentio/kafka-go/pull/947 merged I would expect the Reader and consumer group to be sending the highest...
Your merged PR has been included in release https://github.com/segmentio/kafka-go/releases/tag/v0.4.36 Feel free to close this issue if things are working as expected in that version!
https://github.com/segmentio/kafka-go/pull/1000
I suspect this was fixed by https://github.com/segmentio/kafka-go/pull/869
Thanks for suppling the logs; It's still not entirely clear what's going on. There are these `subscribed to topics and partitions: map[]` lines which seem to indicate that certain group...
It looks like the reader is only showing a single partition for that topic `found topic/partition: TOPIC_NAME/0`. That may be why it's stalling, are you only seeing lag grow on...
> I assume i should do the same with the writer? We also have a recreation of the writer on a failure. I could just loop the writing of the...
Closing due to inactivity.
Hi, we don't have any plans at the moment to expose the reader struct directly. NewReader does quite a bit of setup work when running a consumer group; While it...