Back traces +----------------------------------------------------------------------------------------------------------------+------------------+--------------------+ | Name | Time (ms) | Invocation Count | +----------------------------------------------------------------------------------------------------------------+------------------+--------------------+ | +---kafka.server.KafkaApis.kafka$server$KafkaApis$$ensureTopicExists(String) | 202,875 100 % | 3,430 | | | | | | | +---kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(Tuple2) | | | | | | | | | +---kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$readMessageSets$1.apply(Object) | | | | | | | | | +---scala.collection.TraversableLike$$anonfun$map$1.apply(Object) | | | | | | | | | +---scala.collection.TraversableLike$$anonfun$map$1.apply(Object) | | | | | | | | | +---scala.collection.immutable.HashMap$HashMap1.foreach(Function1) | | | | | | | | | +---scala.collection.immutable.HashMap$HashTrieMap.foreach(Function1) | | | | | | | | | +---scala.collection.immutable.HashMap$HashTrieMap.foreach(Function1) | | | | | | | | | +---scala.collection.TraversableLike$class.map(TraversableLike, Function1, CanBuildFrom) | 113,934 56 % | 1,898 | | | | | | | | | +---scala.collection.immutable.HashMap.map(Function1, CanBuildFrom) | | | | | | | | | | | +---kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(FetchRequest) | | | | | | | | | | | +---kafka.server.KafkaApis.handleFetchRequest(RequestChannel$Request) | 80,084 39 % | 1,240 | | | | | | | | | | | +---kafka.server.KafkaApis.handle(RequestChannel$Request) | | | | | | | | | | | | | +---kafka.server.KafkaRequestHandler.run() | | | | | | | | | | | | | +---java.lang.Thread.run() | | | | | | | | | | | +---kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis$DelayedFetch) | 33,849 17 % | 658 | | | | | | | | | +---kafka.server.KafkaApis$FetchRequestPurgatory.expire(DelayedRequest) | | | | | | | | | | | +---kafka.server.RequestPurgatory$ExpiredRequestReaper.run() | | | | | | | | | | | +---java.lang.Thread.run() | | | | | | | | | +---scala.collection.immutable.HashMap$HashTrieMap.foreach(Function1) | 88,940 44 % | 1,532 | | | | | | | +---scala.collection.TraversableLike$class.map(TraversableLike, Function1, CanBuildFrom) | 86,874 43 % | 1,476 | | | | | | | | | +---scala.collection.immutable.HashMap.map(Function1, CanBuildFrom) | | | | | | | | | | | +---kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(FetchRequest) | | | | | | | | | | | +---kafka.server.KafkaApis.handleFetchRequest(RequestChannel$Request) | 58,058 29 % | 978 | | | | | | | | | | | +---kafka.server.KafkaApis.handle(RequestChannel$Request) | | | | | | | | | | | | | +---kafka.server.KafkaRequestHandler.run() | | | | | | | | | | | | | +---java.lang.Thread.run() | | | | | | | | | | | +---kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis$DelayedFetch) | 28,815 14 % | 498 | | | | | | | | | +---kafka.server.KafkaApis$FetchRequestPurgatory.expire(DelayedRequest) | | | | | | | | | | | +---kafka.server.RequestPurgatory$ExpiredRequestReaper.run() | | | | | | | | | | | +---java.lang.Thread.run() | | | | | | | | | +---scala.collection.immutable.HashMap$HashTrieMap.foreach(Function1) | 2,066 1 % | 56 | | | | | | | +---scala.collection.TraversableLike$class.map(TraversableLike, Function1, CanBuildFrom) | | | | | | | | | +---scala.collection.immutable.HashMap.map(Function1, CanBuildFrom) | | | | | | | | | +---kafka.server.KafkaApis.kafka$server$KafkaApis$$readMessageSets(FetchRequest) | | | | | | | | | +---kafka.server.KafkaApis.handleFetchRequest(RequestChannel$Request) | 1,450 1 % | 36 | | | | | | | | | +---kafka.server.KafkaApis.handle(RequestChannel$Request) | | | | | | | | | | | +---kafka.server.KafkaRequestHandler.run() | | | | | | | | | | | +---java.lang.Thread.run() | | | | | | | | | +---kafka.server.KafkaApis$FetchRequestPurgatory.expire(KafkaApis$DelayedFetch) | 615 0 % | 20 | | | | | | | +---kafka.server.KafkaApis$FetchRequestPurgatory.expire(DelayedRequest) | | | | | | | | | +---kafka.server.RequestPurgatory$ExpiredRequestReaper.run() | | | | | | | | | +---java.lang.Thread.run() | | | +----------------------------------------------------------------------------------------------------------------+------------------+--------------------+ Generated by YourKit Java Profiler 2013 build 13074 Apr 17, 2014 1:05:18 PM