When debugging, be careful not to print the stream itself since it will
block forever.
Thanks,
Jun
On Thu, Dec 12, 2013 at 12:41 PM, Tarang Dawer wrote:
> While debugging, the code got stuck on this call. tried the same by placing
> logs after each call, noticed that whenever consumer got stuc
While debugging, the code got stuck on this call. tried the same by placing
logs after each call, noticed that whenever consumer got stuck, only the
logs before createMessageStreams were printed.
On Fri, Dec 6, 2013 at 9:40 PM, Jun Rao wrote:
> I don't see createMessageStreams in the thread du
I don't see createMessageStreams in the thread dump though. Are you sure
it's stuck there?
Thanks,
Jun
On Fri, Dec 6, 2013 at 1:58 AM, Tarang Dawer wrote:
> Hi Jun
> please find the consumer thread dump in my previous reply.
>
>
> On Fri, Dec 6, 2013 at 3:27 PM, Tarang Dawer
> wrote:
>
> > F
Hi Jun
please find the consumer thread dump in my previous reply.
On Fri, Dec 6, 2013 at 3:27 PM, Tarang Dawer wrote:
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (20.8-b03 mixed mode):
>
> "DestroyJavaVM" prio=10 tid=0x7feb18006800 nid=0xcc2 waiting on
> condition [0x00
Full thread dump Java HotSpot(TM) 64-Bit Server VM (20.8-b03 mixed mode):
"DestroyJavaVM" prio=10 tid=0x7feb18006800 nid=0xcc2 waiting on
condition [0x]
java.lang.Thread.State: RUNNABLE
"consumerGroup675437781_impetus-d898-1386323237902-426eefe2_watcher_executor"
prio=10 ti
Could you take a thread dump and see where the createMessageStreams is
stuck?
Thanks,
Jun
On Wed, Dec 4, 2013 at 4:10 AM, Tarang Dawer wrote:
> Hi All
>
> I am using Kafka 0.8 , with inbuilt zookeeper.
> I am runnings consumers in a jar.
>
>
>
> Configuration properties for creating consumerC
Hi All
I am using Kafka 0.8 , with inbuilt zookeeper.
I am runnings consumers in a jar.
Configuration properties for creating consumerConfig : -
zookeeper.connect=IP
group.id=consumerGroup
fetch.message.max.bytes=10
zookeeper.session.timeout.ms=6
auto.offset.reset=smallest
zookeepe
