Skip to content

Commit c403b1e

Browse files
committed
Fix KafkaTopic::producev causing segfault on librdkafka 1.0.0
Fixes #221
1 parent 4f97323 commit c403b1e

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

topic.c

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -423,6 +423,7 @@ PHP_METHOD(RdKafka__ProducerTopic, producev)
423423
arglen_t key_len = 0;
424424
rd_kafka_resp_err_t err;
425425
kafka_topic_object *intern;
426+
kafka_object *kafka_intern;
426427
HashTable *headersParam = NULL;
427428
HashPosition headersParamPos;
428429
char *header_key;
@@ -464,8 +465,13 @@ PHP_METHOD(RdKafka__ProducerTopic, producev)
464465
headers = rd_kafka_headers_new(0);
465466
}
466467

468+
kafka_intern = get_kafka_object(P_ZEVAL(intern->zrk) TSRMLS_CC);
469+
if (!kafka_intern) {
470+
return;
471+
}
472+
467473
err = rd_kafka_producev(
468-
NULL,
474+
kafka_intern->rk,
469475
RD_KAFKA_V_RKT(intern->rkt),
470476
RD_KAFKA_V_PARTITION(partition),
471477
RD_KAFKA_V_MSGFLAGS(msgflags | RD_KAFKA_MSG_F_COPY),

0 commit comments

Comments
 (0)