kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From S Ahmed <sahmed1...@gmail.com>
Subject Re: first steps with the codebase
Date Tue, 11 Dec 2012 21:21:07 GMT
help anyone? :)

Much much appreciated!


On Tue, Dec 11, 2012 at 12:03 AM, S Ahmed <sahmed1020@gmail.com> wrote:

> 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 <sahmed1020@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.narkhede@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 <sahmed1020@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!
>>>
>>
>>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message