Skip to content

Using rebalance cooperative-sticky #321

@jheffersonalves

Description

@jheffersonalves

Hello,

I'm trying to use the configuration: partition.assignment.strategy = cooperative-sticky
However, after calling the subscribe method, I wonder if cppkafka is internally using rd_kafka_assign, which does not work correctly with cooperative mode.
Am I using the library incorrectly, or does cppkafka not support this mode?

Exception:
%4|1755298323.534|ASSIGN|rdkafka#consumer-1| [thrd:main]: Group "group-test": application *assign() call failed: Changes to the current assignment must be made using incremental_assign() or incremental_unassign() when rebalance protocol type is COOPERATIVE

I'm using this versions:
rdkafka: 1.9.2
cppkafka: 0.3.1

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions