There was an error while loading. Please reload this page.
1 parent e6b9e23 commit 418c19cCopy full SHA for 418c19c
1 file changed
src/confluent_kafka/src/confluent_kafka.h
@@ -292,9 +292,10 @@ typedef struct {
292
PyObject *oauth_cb;
293
atomic_int_t oauth_token_set;
294
295
- /* Protects self->rk from being freed by close() while another method
296
- * is still using it. See Handle_enter_rk_use()/Handle_exit_rk_use()
297
- * in confluent_kafka.c. */
+ /* Protects self->rk in Producer and Admin clients from being freed by
+ * close() while another method is still using it.
+ * See Handle_enter_rk_use()/Handle_exit_rk_use() in confluent_kafka.c.
298
+ */
299
atomic_int_t active_calls;
300
atomic_int_t closing;
301
0 commit comments