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! >
