Send custom dict to kafka using deepstream msgbroker

[ayanasser]

Hello,
I want to send custom msg to kafka using deepstream test4, for example just a dict with img path
msg_data = {“image_path”:“./test.jpg”}

I’ve check the python sample test but I found you’re using specific msg format,
I just want only to use the simple mentioned payload ? how can I do this ?

[yuweiw]

You can try to use the generate_event_msg_meta function to binding your own meta. Also you can refer the link below first:
https://docs.nvidia.com/metropolis/deepstream/dev-guide/text/DS_plugin_gst-nvmsgconv.html

[ayanasser]

@yuweiw
Could you give me a full example for casting the data and sending the msg ?,
I dnt know if I should generate cpp lib function ? or it could just send easily by casting the dict variable I have to another payload type or schema ?

[ayanasser]

or which payload-type integer number I could use to work with custom/ minimal schema
because I’ve tried most of them and it still sending the same full schema

[yuweiw]

You can use the low level library API to custom your own message. Since these code is open source, you can custom the source code nvmsgconv.cpp in your way.