我试图通过使用python API的spark流来从kafka获取数据 .

任何人都知道为什么会出现这个错误

我收到以下错误:错误:root:发送命令时异常 . 回溯(最近一次调用最后一次):文件“/home/shadan/softwares/spark-2.1.1-bin-hadoop2.7/python/lib/py4j-0.10.4-src.zip/py4j/java_gateway.py”,第1035行,在send_command中引发Py4JNetworkError(“从Java端回答为空”)py4j.protocol.Py4JNetworkError:来自Java端的答案是空的

在处理上述异常期间,发生了另一个异常:

回溯(最近一次调用最后一次):文件"/home/shadan/softwares/spark-2.1.1-bin-hadoop2.7/python/lib/py4j-0.10.4-src.zip/py4j/java_gateway.py",第883行,在send_command响应= connection.send_command(命令)文件"/home/shadan/softwares/spark-2.1.1-bin-hadoop2.7/python/lib/py4j-0.10.4-src.zip/py4j/java_gateway.py",第1040行,在send_command "Error while receiving",e,proto.ERROR_ON_RECEIVE)py4j.protocol.Py4JNetworkError:接收 enter code here 时出错