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 d7239ee commit 353ac3fCopy full SHA for 353ac3f
confluent_kafka/src/Consumer.c
@@ -64,6 +64,8 @@ static int Consumer_traverse (Handle *self,
64
Py_VISIT(self->u.Consumer.on_assign);
65
if (self->u.Consumer.on_revoke)
66
Py_VISIT(self->u.Consumer.on_revoke);
67
+ if (self->u.Consumer.on_commit)
68
+ Py_VISIT(self->u.Consumer.on_commit);
69
70
Handle_traverse(self, visit, arg);
71
0 commit comments