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
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