开发者社区> 问答> 正文

kafka.common.KafkaException:错误的请求类型18

社区小助手 2018-12-06 15:46:11 1095

我正在运行这段代码。streamingInputDF是Kafka主题的readStream。我正在运行spark 2.4.0和Kafka 0.10.2

val activityQuery = streamingInputDF.writeStream
.format("console")
.outputMode("append")
.start()
.awaitTermination()
只要在streamingInputDF上调用writeStream,我就会看到Kafka代理抛出此异常

[2018-11-24 21:46:42,842] ERROR Closing socket for /127.0.0.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18

at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
消息中间件 分布式计算 Kafka Spark
分享到
取消 提交回答
全部回答(1)
  • 社区小助手
    2019-07-17 23:18:35

    你需要做的只是重新启动Kafka经纪人其他不改变。

    val activityQuery = streamingInputDF.writeStream
    .format("console")
    .outputMode("append")
    .start()
    .awaitTermination()

    0 0
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题
推荐课程