How to send json data to kafka with deepstream-app and Yolo?

Hi,
I want to use both tracker and msgbroker in a single pipeline. I’ve tried them separately: deepstream-app with tracker and deepstream-test4 with msgbroker, but I don’t understand how to merge them together.

More specfically, how can I run deepstream-app with config file deepstream_app_config_yoloV3.txt, but with tracker and msgbroker working?

1 Like

Hi,
deepstream-app has support for msgconv/msgbroker plugins. You can add new sink of type=6 to use these plugins in your pipeline. You can also refer to deepstream-test5 app how to setup your configuration file.

1 Like

could you elaborate a bit more on this? I am trying to run deepstream-app from a config file so that I get the detections from a csi camera based on config source1_csi_dec_infer_resnet_int8.txt. I have added this sink:

[sink1]
enable=1
type=6
msg-conv-config=/opt/nvidia/deepstream/deepstream-5.0/sources/apps/sample_apps/deepstream-test5/configs/dstest5_msgconv_sample_config.txt
msg-conv-payload-type=0
msg-broker-proto-lib=/opt/nvidia/deepstream/deepstream-5.0/lib/libnvds_kafka_proto.so
msg-broker-conn-str=127.0.0.1;9092;ds_data
topic=ds_data

although it is running and I can see the detections on screen display, no new topic is created at kafka with the results.

Hi d.katsios,

Please help to open a new topic for your issue. Thanks