My bad on 1), fixing it right now. On Sun, Apr 12, 2015 at 8:06 PM, Jun Rao <j...@confluent.io> wrote:
> For 1, the issue seems to be that we try to get metadata using the offset > field. Filed KAFKA-2117. > > Thanks, > > Jun > > On Sun, Apr 12, 2015 at 1:12 PM, Jay Kreps <jay.kr...@gmail.com> wrote: > > > 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 > > > -- -- Guozhang
