Skip to content

[QUESTION] I am using AIOkafka, but i have some question. #933

Closed
@taeyoung-lee-tpv-clt

Description

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

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions