Hello.
Sometimes I see consumer error message [Consumer clientId=xClientId, groupId=xGroupId] Offset commit failed on partition x-2 at offset N: The coordinator is not aware of this member.
in my logs.
I think the first time I saw that message was right after akka-stream-kafka
update from 0.18
to 0.22
.
The most upsetting thing is that consumer dies (I can see it by growing lag), but Consumer.Control
's isShutdown
method return uncompleted Future
of Done
, that is, consumer is up and running.
Is it a bug or normal behavior?