We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6d90fa7 commit e9c9570Copy full SHA for e9c9570
Consumer.c
@@ -582,8 +582,8 @@ PyTypeObject ConsumerType = {
582
583
584
static void Consumer_rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err,
585
- rd_kafka_topic_partition_list_t *c_parts,
586
- void *opaque) {
+ rd_kafka_topic_partition_list_t *c_parts,
+ void *opaque) {
587
Consumer *self = opaque;
588
589
PyEval_RestoreThread(self->thread_state);
0 commit comments