Skip to content

Instantly share code, notes, and snippets.

@aeppert

aeppert/librdkafka_rrpart.cc

Last active April 12, 2018 16:49
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save aeppert/9a623fb6973696e45f8074353796370a to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save aeppert/9a623fb6973696e45f8074353796370a to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. aeppert revised this gist Apr 12, 2018. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion librdkafka_rrpart.cc
    View file
    Original file line number Diff line number Diff line change
    @@ -5,7 +5,7 @@ class RRPartitionerCb : public RdKafka::PartitionerCb {
    const std::string *key,
    int32_t partition_cnt,
    void *msg_opaque) {
    if(partition > (partition_cnt-1) || (partition + 1) > (partition_cnt-1)) {
    if((partition+1) > (partition_cnt-1)) {
    partition = 0;
    return partition;
    }
  2. aeppert created this gist Apr 12, 2018.
    18 changes: 18 additions & 0 deletions librdkafka_rrpart.cc
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,18 @@
    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 > (partition_cnt-1) || (partition + 1) > (partition_cnt-1)) {
    partition = 0;
    return partition;
    }

    partition++;
    return partition;
    }
    private:
    int32_t partition;
    };