[Kafka] "The coordinator is not aware of this member. from time to time in my logs" error


(Dmitriy Zakomirnyi) #1

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?