Python Deepstream test-4 kafka error

Accelerated Computing Intelligent Video Analytics DeepStream SDK
1

Please provide complete information as applicable to your setup.

• Hardware Platform (Jetson / GPU) H100
• DeepStream Version 6.4
• JetPack Version (valid for Jetson only)
• TensorRT Version
• NVIDIA GPU Driver Version (valid for GPU only)
• Issue Type( questions, new requirements, bugs)
• How to reproduce the issue ? (This is for bugs. Including which sample app is using, the configuration files content, the command line used and other details for reproducing)
• Requirement details( This is for new requirement. Including the module name-for which plugin or for which sample application, the function description)

Hi, I am running the python deepstream test4 to test out on the message broker feature on deepstream. However, it outputs below error:

e> error: streaming stopped, reason not-negotiated (-4)
Frame Number = 2 Vehicle Count = 9 Person Count = 1
Frame Number = 3 Vehicle Count = 9 Person Count = 2
Error: gst-stream-error-quark: Internal data stream error. (1): gstnvinfer.cpp(2406): gst_nvinfer_output_loop (): /GstPipeline:pipeline0/GstNvInfer:primary-inference:
streaming stopped, reason not-negotiated (-4)
%3|1719559328.003|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: ApiVersionRequest failed: Local: Timed out: probably due to broker version < 0.10 (see api.version.request configuration) (after 10010ms in state APIVERSION_QUERY)
%3|1719559328.003|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: ApiVersionRequest failed: Local: Timed out: probably due to broker version < 0.10 (see api.version.request configuration) (after 10010ms in state APIVERSION_QUERY, 1 identical error(s) suppressed)
%3|1719559328.003|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: ApiVersionRequest failed: Local: Timed out: probably due to broker version < 0.10 (see api.version.request configuration) (after 10009ms in state APIVERSION_QUERY, 3 identical error(s) suppressed)
%3|1719559328.003|ERROR|rdkafka#producer-1| [thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: ApiVersionRequest failed: Local: Timed out: probably due to broker version < 0.10 (see api.version.request configuration) (after 10009ms in state APIVERSION_QUERY, 3 identical error(s) suppressed)
nvstreammux: Successfully handled EOS for source_id=0

I am using the kbzimage/wurstmeister-zookeeper for zookeeper and apache/kafka for messagebroker in the docker container. Any advice on why is it producing this error?

3

it is related to the kafka server settings. please refer to this topic.

4

When it mentioned about “kafka server.properties”, may i know where can i find the config file to change the settings in it?

5

DeepStream kafka client is opensource. please refer to /opt/nvidia/deepstream/deepstream/sources/libs/kafka_protocol_adaptor/.
as for the kafka server, using kafka kafka_2.13-3.3.1.tgz, I can’t reproduce this issue. Here is kafka server setting method.

6

There is no update from you for a period, assuming this is not an issue anymore. Hence we are closing this topic. If need further support, please open a new one. Thanks

7

This topic was automatically closed 14 days after the last reply. New replies are no longer allowed.