Specifying multiple brokers with conn-str Gst-nvmsgbroker

Accelerated Computing Intelligent Video Analytics DeepStream SDK
1

Hi,

Is it possible to define multiple brokes instead of one with the ‘conn-str’ of Gst-nvmsgbroker? It seems that there’s only one host available?

https://github.com/Kwull/deepstream-4.0.1/blob/master/sources/libs/kafka_protocol_adaptor/nvds_kafka_proto.cpp#L322

Thanks.

2

Multiple brokers can be used by using multiple sinks of type = 6,
but multiple brokers have issue which is about messages sent duplicated using DS 4.0.2. The fix will be in an upcoming release, you can find this topic which is about multiple brokers,

https://devtalk.nvidia.com/default/topic/1065359/deepstream-sdk/amqp-bug-regarding-username-and-topic-definition/post/5422113/#5422113

3

We’re not working with the config sinks. We use the ‘nvinfer’ object directly in our pipeline.

msgbroker = gst_element_factory_make ("nvmsgbroker", "nvmsg-broker");
g_object_set(G_OBJECT(msgbroker), "conn-str", KAFKA_CONNECTION_STRING_PRIMARY, NULL);

As far as I can see, this method should be updated to handle connection string with more brokers:

https://github.com/Kwull/deepstream-4.0.1/blob/master/sources/libs/kafka_protocol_adaptor/nvds_kafka_proto.cpp#L262

4

Yeah, multi brokers supported, config form or coded directly, both fine.
and please read comment 2# conscientiously.