This issue was moved to a discussion.
You can continue the conversation there. Go to discussion →
[QUESTION] I am using AIOkafka, but i have some question. #933
Labels
You can continue the conversation there. Go to discussion →
while I'm using AIOkafka but sometimes when I using 'consumer.commit()'
At that time, I found this error on the log
'commit cannot be completed since the group has already rebalanced'
so when i find some information.
then they said to me the AIOkafka have an autocommoit.
so I changed to passive-commit = False
I use this code 'consumer.commit()'.
I've written it the end of the process after service part
service1.handler()
service2.handler()
service3.handler()
consumer.commit()
like this
so but how can i overcome this horrible situation
i want to solve this problem of rebalanced error when i commit()
eventually, i changed poll size and ms time
so please answer to me except for this option
thank you
The text was updated successfully, but these errors were encountered: