Skip to content

Commit 8dcad18

Browse files
author
Peter Yin
committed
misc fixes to errors and warnings when building
1 parent e0be387 commit 8dcad18

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

confluent_kafka/src/Producer.c

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -532,18 +532,19 @@ static PyObject *Producer_abort_transaction(Handle *self, PyObject *args) {
532532
Py_RETURN_NONE;
533533
}
534534

535-
static PyObject *Producer_purge (Handle *self, PyObject *args,
535+
static void *Producer_purge (Handle *self, PyObject *args,
536536
PyObject *kwargs) {
537537
int purge_strategy;
538538
int blocking = 0;
539+
rd_kafka_resp_err_t err;
539540
static char *kws[] = { "purge_strategy", "blocking", NULL};
540541

541542
if (!PyArg_ParseTupleAndKeywords(args, kwargs, "i|p", kws, &blocking))
542543
return NULL;
543544
if (blocking==1)
544-
err = rd_kafka_purge(rk, purge_strategy)
545+
err = rd_kafka_purge(self->rk, purge_strategy);
545546
else
546-
err = rd_kafka_purge(rk, purge_strategy|RD_KAFKA_PURGE_F_NON_BLOCKING)
547+
err = rd_kafka_purge(self->rk, purge_strategy|RD_KAFKA_PURGE_F_NON_BLOCKING);
547548
if (err == RD_KAFKA_RESP_ERR_NO_ERROR) {
548549
Py_RETURN_NONE;
549550
}

0 commit comments

Comments
 (0)