Kafka在消费消息时崩溃

Question

Kafka过去在我自己的电脑上工作得很好。我正在另一台电脑上工作，上面写着

为目录C:\tmp\kafka logs（kafka.server.LogDirFailureChannel）java中的\uu consumer\u offset-41创建日志时出错。木卫一。IOException:映射在sun失败。尼奥。总经理。Kafka地图（FileChannelImpl.java:940）。日志抽象索引。（AbstractIndex.scala:126）在Kafka。日志时间索引。（时间索引：scala:54）在Kafka。日志对数段$。在Kafka开放（LogSegment.scala:635）。日志日志Kafka的loadSegments（Log.scala:573）。日志日志（日志：scala:290）在Kafka。日志日志$。在Kafka应用（Log.scala:2141）。日志日志管理器$scala上的anonfun$getOrCreateLog$1（LogManager.scala:701）。选项Kafka的getOrElse（Option.scala:121）。日志日志管理器。在Kafka的getOrCreateLog（LogManager.scala:659）。簇分割$kafka上的anonfun$getOrCreateReplica$1（Partition.scala:199）。乌提尔斯。池$$anon$2。在java上应用（Pool.scala:61）。util。同时发生的ConcurrentHashMap。Kafka的computeIfAbsent（ConcurrentHashMap.java:1660）。乌提尔斯。水塘getAndMaybePut（Pool.scala:60）在Kafka。簇隔断在Kafka的getOrCreateReplica（Partition.scala:195）。簇分割$scala上的anonfun$makeLeader$3（Partition.scala:373）。收集我喜欢$scala上的anonfun$map$1（TraversableLike.scala:233）。收集迭代器。scala上的foreach（迭代器.scala:937）。收集迭代器。scala上的foreach$（Iterator.scala:937）。收集抽象迭代器。scala上的foreach（迭代器.scala:1425）。收集伊特拉布雷利克。scala的foreach（IterableLike.scala:70）。收集伊特拉布雷利克。scala的foreach$（类似IterableLike.scala:69）。收集抽象的。scala的foreach（Iterable.scala:54）。收集我喜欢。scala上的map（TraversableLike.scala:233）。收集我喜欢。将$（TraversableLike.scala:226）映射到scala。收集抽象可遍历。Kafka地图（可遍历，scala:104）。簇分割$kafka上的anonfun$makeLeader$1（Partition.scala:373）。乌提尔斯。CoreUtils$。Kafka的inLock（CoreUtils.scala:251）。乌提尔斯。CoreUtils$。Kafka的inWriteLock（CoreUtils.scala:259）。簇隔断Kafka的makeLeader（Partition.scala:367）。服务器复制经理$scala的anonfun$makeLeaders$5（ReplicaManager.scala:1170）。收集易变的。哈希映射$scala上的anonfun$foreach$1（HashMap.scala:145）。收集易变的。哈希表。scala的foreachEntry（HashTable.scala:235）。收集易变的。哈希表。scala上的foreachEntry$（HashTable.scala:228）。收集易变的。哈希映射。scala的foreachEntry（HashMap.scala:40）。收集易变的。哈希映射。Kafka的foreach（HashMap.scala:145）。服务器复制经理。Kafka的makeLeaders（ReplicaManager.scala:1168）。服务器复制经理。成为Kafka的领导者或追随者（ReplicaManager.scala:1080）。服务器Kafka皮斯。在Kafka的HandleLeaderAndisRequest（Kafka皮斯.斯卡拉：185）。服务器Kafka皮斯。Kafka的把手（Kafka皮斯.斯卡拉：110）。服务器Kafka雷克斯特汉德勒。在java上运行（KafkaRequestHandler.scala:69）。朗。丝线。运行（Thread.java:745）的原因是：java。lang.OutOfMemoryError:映射在sun失败。尼奥。总经理。sun的map0（本机方法）。尼奥。总经理。映射（FileChannelImpl.java:937）。。。41更多[2019-03-25 14:55:00296]信息[ReplicaManager broker=0]停止在目录C:\tmp\kafka日志（kafka.server.ReplicaManager）[2019-03-25 14:55:00296]错误[ReplicaManager broker=0]中提供副本，使broker成为分区主题的领导者时出错：\u consumer\u offset；分区：41；组长：无；所有副本：；InSyncReplicas:in dir None（kafka.server.ReplicaManager）

每当我试图通过发出以下命令来使用主题时，就会出现此错误：

bin\windows\kafka控制台使用者。bat--引导服务器本地主机：9092--主题更新观察服务器--从一开始

我的java版本是：

java版本“1.8.0_91”java（TM）SE运行时环境（构建1.8.0_91-b15）java热点（TM）64位服务器虚拟机（构建25.91-b15，混合模式）

ps：删除tmp目录并不能解决问题，它只是让我能够再次启动Kafka，一旦我想从给定的主题消费它就会崩溃

Answer 1

面对同样的问题。将Java版本升级到16.0。我会解决我的问题。还将JAVA_HOME设置为16版本，不带bin文件夹。例如C:\ProgramFiles\Java\jdk-16.0。1.