How to connect to a kafka cluster

Please provide complete information as applicable to your setup.

• Hardware Platform GPU
**• DeepStream Version 5.0.1
• TensorRT Version 7.0.1
• Issue Type questions
• Requirement details
I have a kafka cluster with 3 nodes. And I want to send messages to it using deepstream. But the format of msg-broker-conn-str in configure file of deepstream-app is “ip;port;topic”. I’ve tried to add 2 ips with their ports. But the connection was failed. So how should I configure to connect to my Kafka cluster?

It may not support kafka cluster or multiple kafka brokers while I found some related codes in nvds_kafka_proto.cpp. Will deepstream support this feature? And I’m going to modify some code to connect to my kafka cluster.


Based on our document, multiple brokers is supported:

Deepstream 5.0 features a new messagebroker library which can be used to make connections with multiple external brokers. …

Please find more usage details in the document.