Python deepstream-test4 cannot connect Kafka

Please provide complete information as applicable to your setup.

• Hardware Platform (Jetson / GPU)
• DeepStream Version5.1
• JetPack Version (valid for Jetson only)4.5.1
• TensorRT Version7.1.3.0
Hi

First, I installed the Kafka service on X86 according to the tutorial, and successfully created the topic(Start the ZooKeeper service and Start the Kafka broker service),Then, Install the relevant dependency (librdkafka、glib 2.0、jansson) according to sources/libs/kafka_protocol_adaptor/README.Finally, modify Kafka’s configuration file (cfg_kafka.txt):

[message-broker]
consumer-group-id = “quickstart-events”
proto-cfg = “message.max.bytes=200000;log_level=6”
producer-proto-cfg = “queue.buffering.max.messages=200000;message.send.max.retries=3”
consumer-proto-cfg = “max.poll.interval.ms=20000”
partition-key = “123456”
#share-connection = 1
quickstart-events:The name of the topic.
123456:I don’t know how to get it, so I wrote it at will

Finally, run the following command:
sudo python3 deepstream_test_4.py -i ‘/opt/nvidia/deepstream/deepstream-5.1/samples/streams/sample_720p.h264’ -p ‘/opt/nvidia/deepstream/deepstream-5.1/lib/libnvds_kafka_proto.so’ --conn-str=‘192.168.31.34;9092;quickstart-events’ -s=0


How can I solve this problem?

Thank you very much. I’m running

Glad to know it’s working, thanks for the update!