In the Deepstream-app sample, I add a sink “msgconv-msgbroker” into the pipeline. I should have set it rightly. But I cannot get the message in other end, kafka. I wonder if the msgconv lib is Ok, so I print something in the function nvds_msg2p_generate. It does not output anything. So this function does not work. Which function is must be conducted? How can I know what is happening?
ps. I did not receive any error feedback, but many warns about broker like the following:
WARN: <broker_queue_overrun:185>: nvmsgbroker queue overrun; Older Message Buffer Dropped; Network bandwidth might be insufficient
If I change the parameter from “msg-broker-conn-str=127.0.0.1;9092;test” to “msg-broker-conn-str=127.0.0.1;9092:test”, a error will be feedback.
Thanks a lot for any suggestion.