rd_kafka_assign

@brief Atomic assignment of partitions to consume.

The new \p partitions will replace the existing assignment.

When used from a rebalance callback the application shall pass the partition list passed to the callback (or a copy of it) (even if the list is empty) rather than NULL to maintain internal join state.

A zero-length \p partitions will treat the partitions as a valid, albeit empty, assignment, and maintain internal state, while a \c NULL value for \p partitions will reset and clear the internal state.

extern (C) nothrow @nogc
rd_kafka_assign

Meta