我正面临与 Kafka 相关的问题。
我的当前服务 ( Producer) 将消息发送到 Kafka 主题 ( events)。该服务正在使用kafka_2.12 v1.0.0，用 Java 编写。
我正在尝试将它与spark-streaming作为Consumer服务的示例项目集成（这里使用 kafka_2.11 v0.10.0，用 Scala 编写）
消息成功发送Producer到 Kafka 主题。但是，我总是收到以下错误堆栈：
Exception in thread "main" org.apache.kafka.common.errors.InconsistentGroupProtocolException: The group member's supported protocols are incompatible with those of existing members.
at ... run in separate thread using org.apache.spark.util.ThreadUtils ... ()
at org.apache.spark.streaming.StreamingContext.liftedTree1$1(StreamingContext.scala:577)
at org.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:571) at com.jj.streaming.ItemApp$.delayedEndpoint$com$jj$streaming$ItemApp$1(ItemApp.scala:72)
at com.jj.streaming.ItemApp$delayedInit$body.apply(ItemApp.scala:12)
at scala.Function0$class.apply$mcV$sp(Function0.scala:34)
at scala.runtime.AbstractFunction0.apply$mcV$sp(AbstractFunction0.scala:12) at scala.App$$anonfun$main$1.apply(App.scala:76)
at scala.App$$anonfun$main$1.apply(App.scala:76)
at scala.collection.immutable.List.foreach(List.scala:381)
at …我面临一个奇怪的问题。我试图找到解决方案来解决，但我仍然找不到。
我在我的应用程序中使用该代码
require('os').tmpdir()
它返回当前工作区文件夹 /srv/workspace/
节点-e“console.log(require('os').tmpdir())”
它返回/tmp
该问题发生在虚拟机和服务器上。我的主机上不会发生这种情况。
节点：v5.7.1
新PM：3.9.5
谁能帮我？