librdkafka round-robin partitioner

librdkafka_rrpart.cc

class RRPartitionerCb : public RdKafka::PartitionerCb {
 public:
    RRPartitionerCb() { partition = 0; }
    int32_t partitioner_cb(const RdKafka::Topic *topic, 
                           const std::string *key,
                           int32_t partition_cnt, 
                           void *msg_opaque) {
        if((partition+1) > (partition_cnt-1)) {
            partition = 0;
            return partition;
        } 
        
        partition++;
        return partition;
    }
 private:
    int32_t partition;
};

Ah, indeed you would be correct. That is the simplification. This is what happens when one writes code at 1AM takes a nap and still has the over-complicated logic in one's head... Thank you for that!.