Destroy rd_kafka_t handle on consumer.close() (#30)

edenhill · edenhill · commit ab402c2baba3 · 2016-08-19T10:10:01.000+02:00
diff --git a/confluent_kafka/src/Consumer.c b/confluent_kafka/src/Consumer.c
@@ -399,6 +399,9 @@ static PyObject *Consumer_close (Handle *self, PyObject *ignore) {
 	if (!CallState_end(self, &cs))
 		return NULL;
 
+	rd_kafka_destroy(self->rk);
+	self->rk = NULL;
+
 	Py_RETURN_NONE;
 }
 

Original file line number	Diff line number	Diff line change
`@@ -399,6 +399,9 @@ static PyObject Consumer_close (Handle self, PyObject *ignore) {`
`399`	`399`	`if (!CallState_end(self, &cs))`
`400`	`400`	`return NULL;`
`401`	`401`
	`402`	`+ rd_kafka_destroy(self->rk);`
	`403`	`+ self->rk = NULL;`
	`404`	`+`
`402`	`405`	`Py_RETURN_NONE;`
`403`	`406`	`}`
`404`	`407`