Free opaque in dr_msg_cb

[asanchez1987]

In a producer application I'm doing this:

uint32_t *opaque = NULL;
opaque = xmalloc(sizeof(*opaque));
*opaque = kafka_msg->job_id;
err = rd_kafka_producev(rk, ..., RD_KAFKA_V_OPAQUE(opaque), RD_KAFKA_V_END);

Then in the dr_msg_cb:

xfree(rkmessage->_private);

But Valgrind still reports the xmalloc'd memory as leaked. From my understanding of librdkafka docs and reading the code, the lib makes a copy of the topic, also a copy of the payload if RD_KAFKA_MSG_F_COPY but not a copy of the opaque. So I'm manually allocating memory for the opaque and then attempting to free it in the callback.

Any suggestions?

[asanchez1987]

It just turns out the application needed to xfree the opaque also on err. So just an oversight. This can be marked as answered.