获取错误 py4j.protocol.Py4JNetworkError：Java 端的答案在 Spark 流中为空

Question

我正在尝试使用带有 python API 的火花流从 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("Answer from Java side is empty") py4j.protocol.Py4JNetworkError: Answer from Java side is empty

在处理上述异常的过程中，又发生了一个异常：

回溯（最近一次通话）：文件“/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(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 “接收时出错”，e，proto.ERROR_ON_RECEIVE）py4j.protocol.Py4JNetworkError：接收时出错enter code here