I see the following issues on trunk when doing almost anything:
1. Offset manager: it looks like this code has never been run, there is a type that tries to read the offset as a string. java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.String at kafka.server.OffsetManager$.kafka$server$OffsetManager$$readMessageValue(OffsetManager.scala:576) at kafka.server.OffsetManager$$anonfun$kafka$server$OffsetManager$$loadOffsets$1$2.apply(OffsetManager.scala:388) at kafka.server.OffsetManager$$anonfun$kafka$server$OffsetManager$$loadOffsets$1$2.apply(OffsetManager.scala:377) at scala.collection.Iterator$class.foreach(Iterator.scala:727) at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at kafka.message.MessageSet.foreach(MessageSet.scala:67) at kafka.server.OffsetManager.kafka$server$OffsetManager$$loadOffsets$1(OffsetManager.scala:377) at kafka.server.OffsetManager$$anonfun$loadOffsetsFromLog$1.apply$mcV$sp(OffsetManager.scala:358) at kafka.utils.KafkaScheduler$$anonfun$1.apply$mcV$sp(KafkaScheduler.scala:108) at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:60) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) at java.util.concurrent.FutureTask.run(FutureTask.java:262) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) 2. Errors in RequestChannel when updating metrics: kafka.common.KafkaException: Wrong request type 12 at kafka.api.RequestKeys$.nameForKey(RequestKeys.scala:55) at kafka.network.RequestChannel$Request.updateRequestMetrics(RequestChannel.scala:85) at kafka.network.Processor.write(SocketServer.scala:514) at kafka.network.Processor.run(SocketServer.scala:379) at java.lang.Thread.run(Thread.java:744) [2015-04-12 12:54:52,077] INFO [Kafka Coordinator 0]: Registered consumer my-group-24 for group my-group (kafka.coordinator.ConsumerCoordinator) [2015-04-12 12:54:52,080] INFO [Kafka Coordinator 0]: Handled join-group from consumer to group my-group (kafka.coordinator.ConsumerCoordinator) [2015-04-12 12:54:52,081] ERROR Closing socket for /10.0.0.220 because of error (kafka.network.Processor) kafka.common.KafkaException: Wrong request type 11 at kafka.api.RequestKeys$.nameForKey(RequestKeys.scala:55) at kafka.network.RequestChannel$Request.updateRequestMetrics(RequestChannel.scala:85) at kafka.network.Processor.write(SocketServer.scala:514) at kafka.network.Processor.run(SocketServer.scala:379) at java.lang.Thread.run(Thread.java:744) -Jay
