Skip to content

Commit 926e55e

Browse files
author
Roopa Hiremath Chandrasekaraiah
committed
AvroProducer for handling schema registry
1 parent 7997cd8 commit 926e55e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

confluent_kafka/src/confluent_kafka.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1218,7 +1218,6 @@ rd_kafka_conf_t *common_conf_setup (rd_kafka_type_t ktype,
12181218
rd_kafka_topic_conf_destroy(tconf);
12191219
rd_kafka_conf_destroy(conf);
12201220
Py_DECREF(ks);
1221-
12221221
return NULL;
12231222
}
12241223
if (h->error_cb) {
@@ -1241,6 +1240,7 @@ rd_kafka_conf_t *common_conf_setup (rd_kafka_type_t ktype,
12411240
Py_DECREF(ks);
12421241
return NULL;
12431242
}
1243+
12441244
if (h->stats_cb) {
12451245
Py_DECREF(h->stats_cb);
12461246
h->stats_cb = NULL;

0 commit comments

Comments
 (0)