BTW, where exactly will the broker be writing these messages? Is it in a /tmp folder?
On Tue, Dec 11, 2012 at 12:02 AM, S Ahmed <sahmed1...@gmail.com> wrote: > Neha, > > But what do I need to start before running the tests, I tried to run the > test "testAsyncSendCanCorrectlyFailWithTimeout" but I got this: > > 2012-12-11 00:01:08,974] WARN EndOfStreamException: Unable to read > additional data from client sessionid 0x13b8856456a0002, likely client has > closed socket (org.apache.zookeeper.server.NIOServerCnxn:634) > [2012-12-11 00:01:11,231] WARN EndOfStreamException: Unable to read > additional data from client sessionid 0x13b8856456a0001, likely client has > closed socket (org.apache.zookeeper.server.NIOServerCnxn:634) > [2012-12-11 00:01:26,561] WARN EndOfStreamException: Unable to read > additional data from client sessionid 0x13b8856456a0003, likely client has > closed socket (org.apache.zookeeper.server.NIOServerCnxn:634) > [2012-12-11 00:01:26,563] WARN EndOfStreamException: Unable to read > additional data from client sessionid 0x13b8856456a0004, likely client has > closed socket (org.apache.zookeeper.server.NIOServerCnxn:634) > [2012-12-11 00:01:30,661] ERROR [TopicChangeListener on Controller 1]: > Error while handling new topic > (kafka.controller.PartitionStateMachine$TopicChangeListener:102) > java.lang.NullPointerException > at > scala.collection.JavaConversions$JListWrapper.iterator(JavaConversions.scala:524) > at scala.collection.IterableLike$class.foreach(IterableLike.scala:79) > at > scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:521) > at > scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:176) > at > scala.collection.JavaConversions$JListWrapper.foldLeft(JavaConversions.scala:521) > at > scala.collection.TraversableOnce$class.$div$colon(TraversableOnce.scala:139) > at > scala.collection.JavaConversions$JListWrapper.$div$colon(JavaConversions.scala:521) > at scala.collection.generic.Addable$class.$plus$plus(Addable.scala:54) > at scala.collection.immutable.Set$EmptySet$.$plus$plus(Set.scala:47) > at scala.collection.TraversableOnce$class.toSet(TraversableOnce.scala:436) > at > scala.collection.JavaConversions$JListWrapper.toSet(JavaConversions.scala:521) > at > kafka.controller.PartitionStateMachine$TopicChangeListener.liftedTree1$1(PartitionStateMachine.scala:337) > at > kafka.controller.PartitionStateMachine$TopicChangeListener.handleChildChange(PartitionStateMachine.scala:335) > at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:570) > at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) > Disconnected from the target VM, address: '127.0.0.1:64026', transport: > 'socket' > > > > > On Mon, Dec 10, 2012 at 11:54 PM, Neha Narkhede > <neha.narkh...@gmail.com>wrote: > >> You can take a look at one of the producer tests and attach >> breakpoints in the code. Ensure you pick the Debug Test instead of Run >> Test option. >> >> Thanks, >> Neha >> >> On Mon, Dec 10, 2012 at 7:31 PM, S Ahmed <sahmed1...@gmail.com> wrote: >> > Hi, >> > >> > So I followed the instructions from here: >> > https://cwiki.apache.org/confluence/display/KAFKA/Developer+Setup >> > >> > So I pulled down the latest from github, ran; >> > sbt >> >> update >> >>idea >> > >> > open it up in idea, and builds fine in idea also (version 12). >> > >> > Everything is fine so far. >> > >> > Questions: >> > >> > From just using the IDE, how can I start the neccessary services so I >> can >> > debug a producer call so I can trace the code line by line as it >> executes >> > to create a message, and then set a breakpoint on the kafka server side >> of >> > things to see how it goes about processing an inbound message. >> > >> > Is this possible, or is the general workflow first starting the services >> > using some .sh scripts? >> > >> > My goal here is to be able to set breakpoints on both the producer and >> > broker side of things. >> > >> > Much appreciated! >> > >
