Skip to content

Commit

Permalink
Remove unused variable
Browse files Browse the repository at this point in the history
  • Loading branch information
Silviu Caragea committed Apr 13, 2019
1 parent d5ff837 commit c63dc65
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions c_src/erlkaf_consumer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@ struct enif_consumer

struct enif_queue
{
int32_t partition;
rd_kafka_queue_t* queue;
enif_consumer* consumer;
};
Expand All @@ -45,7 +44,6 @@ enif_queue* enif_new_queue(enif_consumer* consumer, rd_kafka_t* rk, const std::s
consumer->qm_->add(partition_queue);

enif_queue* q = static_cast<enif_queue*>(enif_alloc_resource(consumer->res_queue, sizeof(enif_queue)));
q->partition = partition;
q->queue = partition_queue;
q->consumer = consumer;
return q;
Expand Down

0 comments on commit c63dc65

Please sign in to comment.