[
https://issues.apache.org/jira/browse/KAFKA-5805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ray Chiang updated KAFKA-5805:
------------------------------
Component/s: consumer
> The console consumer crushes broker on Windows
> ----------------------------------------------
>
> Key: KAFKA-5805
> URL: https://issues.apache.org/jira/browse/KAFKA-5805
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 0.11.0.0
> Environment: Windows 7 x86 || Windows 10 x64
> jre1.8.0_144
> jdk1.8.0_144
> Reporter: Aleksandar
> Priority: Critical
> Labels: windows
>
> I was just following Quick start guide on
> http://kafka.apache.org/documentation.html#quickstart
> Started ZooKeeper server
> Started Kafka Server
> Created Test topic
> Published message under test topic
> On other terminal windows I run kafka-console-consumer.bat and that crushed
> Broker with following exception:
> java.io.IOException: Map failed
> at sun.nio.ch.FileChannelImpl.map(Unknown Source)
> at kafka.log.AbstractIndex.<init>(AbstractIndex.scala:63)
> at kafka.log.OffsetIndex.<init>(OffsetIndex.scala:52)
> at kafka.log.LogSegment.<init>(LogSegment.scala:77)
> at kafka.log.Log.loadSegments(Log.scala:385)
> at kafka.log.Log.<init>(Log.scala:179)
> at kafka.log.Log$.apply(Log.scala:1580)
> at kafka.log.LogManager$$anonfun$createLog$1.apply(LogManager.scala:417)
> at kafka.log.LogManager$$anonfun$createLog$1.apply(LogManager.scala:412)
> at scala.Option.getOrElse(Option.scala:121)
> at kafka.log.LogManager.createLog(LogManager.scala:412)
> at
> kafka.cluster.Partition$$anonfun$getOrCreateReplica$1.apply(Partition.scala:122)
> at
> kafka.cluster.Partition$$anonfun$getOrCreateReplica$1.apply(Partition.scala:119)
> at kafka.utils.Pool.getAndMaybePut(Pool.scala:70)
> at kafka.cluster.Partition.getOrCreateReplica(Partition.scala:118)
> at
> kafka.cluster.Partition$$anonfun$3$$anonfun$5.apply(Partition.scala:179)
> at
> kafka.cluster.Partition$$anonfun$3$$anonfun$5.apply(Partition.scala:179)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.Iterator$class.foreach(Iterator.scala:891)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at kafka.cluster.Partition$$anonfun$3.apply(Partition.scala:179)
> at kafka.cluster.Partition$$anonfun$3.apply(Partition.scala:173)
> at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:213)
> at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:221)
> at kafka.cluster.Partition.makeLeader(Partition.scala:173)
> at
> kafka.server.ReplicaManager$$anonfun$makeLeaders$4.apply(ReplicaManager.scala:929)
> at
> kafka.server.ReplicaManager$$anonfun$makeLeaders$4.apply(ReplicaManager.scala:928)
> at
> scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
> at
> scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
> at
> scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:236)
> at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
> at scala.collection.mutable.HashMap.foreach(HashMap.scala:130)
> at kafka.server.ReplicaManager.makeLeaders(ReplicaManager.scala:928)
> at
> kafka.server.ReplicaManager.becomeLeaderOrFollower(ReplicaManager.scala:873)
> at kafka.server.KafkaApis.handleLeaderAndIsrRequest(KafkaApis.scala:168)
> at kafka.server.KafkaApis.handle(KafkaApis.scala:101)
> at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:66)
> at java.lang.Thread.run(Unknown Source)
> Caused by: java.lang.OutOfMemoryError: Map failed
> at sun.nio.ch.FileChannelImpl.map0(Native Method)
> ... 43 more
> [2017-08-29 18:36:37,110] INFO [Group Metadata Manager on Broker 0]: Removed
> 0 expired offsets in 0 milliseconds.
> (kafka.coordinator.group.GroupMetadataManager)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
