Configure Kafka header content through nvmsgconv or nvmsgbroker

Please provide complete information as applicable to your setup.

• Hardware Platform (Jetson / GPU) GPU
• DeepStream Version nvcr.io/nvidia/deepstream:7.1-gc-triton-devel
• JetPack Version (valid for Jetson only)
• TensorRT Version
• NVIDIA GPU Driver Version (valid for GPU only)
• Issue Type( questions, new requirements, bugs) questions
• How to reproduce the issue ? (This is for bugs. Including which sample app is using, the configuration files content, the command line used and other details for reproducing)
• Requirement details( This is for new requirement. Including the module name-for which plugin or for which sample application, the function description)

Hi All,
I am using nvmsgconv and a custom library to parse the metadata into a json string for nvmsgbroker to send it to kafka. I did a quick search on both plugins, and in the forum and could not find any option and resource on settings the message header. Please kindly advise.

nvmsgroker plguin and kafka protocol adapter are opensource from DS7.0. why do you need to set message header? which part of header do you need to set?

I am integrating it to some legacy system that some downstream system use the header to query information. It will be nice if such properties exist.

nvds_msgapi_do_work: Message sent = {#012  "messageid" : "12dddb5a-31de-40f0-be3a-ae7244117604",#012  "mdsversion" : "1.0",#012  "@timestamp" : "2025-04-15T15:14:22.443Z",#012

the message headers above can be modified in generate_dsmeta_message/generate_event_message in nvmsgconv low-level library. do you still need to modify other headers?

Yes i am aware of the low level library for nvmsgconv. The function generate_event_message only parse the json object into a json string and allow it to be sent by nvmsgbroker. My issues is I need to modify the header from the kafka message, not the data. It seesm it will take considerable amount of effort to read and change ngmsgborker, and kafka_protocol_adaptor. I will use custom probe at the moment. Thanks.

Sorry for the late reply, Is this still an DeepStream issue to support? Thanks!

Not at the moment. I will use probe to handle the message sending part. And maybe develop a new plugin later.