I understand that user_meta_copy_func
and user_meta_release_func
is now deprecated functionality and has moved into the python bindings in event_msg_meta_copy_func
.
However, if one wants to use custom functionality (e.g. set extMsg to a string or a CustomDataStruct), I have to modify event_msg_meta_copy_func
and event_msg_meta_release_func
and then rebuild pyds
.
I also have to modify eventmsg_payload.cpp
to process my custom extMsg
(e.g. parse extMsg string as JsonObject) and rebuild libnvds_msgconv.so (and install it to /opt/nvidia/deepstream/deepstream/lib/ ). This led to this issue which is still unsolved for me.
As a result, I cannot use any of the solutions for custom objects or schema customization.
Therefore, I would like to ask how I can pass custom messages (create custom payload without nvmsgconv) to nvmsgbroker directly, or any alternatives (e.g. use kafka-python directly? What are the disadvantages in performance/asynchronous processing?
Thank you for your help.