kafka_2.11-0.9.0.1 crash with java coredump

2016-12-14 Thread Mazhar Shaikh
?? () #16 0xbf2f05e8 in ?? () #17 0x in ?? () #18 0xc3b27610 in ?? () #19 0xbed92898 in ?? () #20 0xe269aac8 in ?? () #21 0x in ?? () Can anyone suggest a solution to overcome this issue. Thank you. Mazhar Shaikh.

Text error in documentation.html web page

2016-10-06 Thread Mazhar Shaikh
Visit: http://kafka.apache.org/documentation.html#quickstart and scroll down. Please find the image attached. [image: Inline image 1] Browser : IE & Firefox

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-09-05 Thread Mazhar Shaikh
oker replicates these messages to leader instead of dropping it ? Thank you. Regards, Mazhar Shaikh. On Tue, Aug 30, 2016 at 6:42 PM, Mazhar Shaikh wrote: > Hi Jun, > > Yes, the data is lost during leader broker failure. > But the leader broker failed due to zookeeper session expiry.

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-30 Thread Mazhar Shaikh
sessionid 0x156c616475a0001, likely client has closed socket at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) at java.lang.Thread.run(Thread.java:744) Thank you. Regards, Mazhar Shaikh On

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-19 Thread Mazhar Shaikh
messages. I just want to know, as when can we get the fix for this bug ? Thanks. Regards, Mazhar Shaikh On Fri, Aug 19, 2016 at 1:24 AM, Jun Rao wrote: > Mazhar, > > With ack=1, whether you lose messages or not is not deterministic. It > depends on the time when the broker rec

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-18 Thread Mazhar Shaikh
automatically. You can increase the > socket idle time on the broker if you want to turn off this behavior. > > Thanks, > > Jun > > On Thu, Aug 18, 2016 at 12:07 AM, Mazhar Shaikh < > mazhar.shaikh...@gmail.com> > wrote: > > > Hi Jun, > > > > S

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-18 Thread Mazhar Shaikh
Shaikh. On Thu, Aug 18, 2016 at 12:37 PM, Mazhar Shaikh wrote: > Hi Jun, > > Setting to -1, may solve this issue. > But it will cause producer buffer full in load test resulting to failures > and drop of messages from client(producer side) > Hence, this will not actually solve

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-18 Thread Mazhar Shaikh
ler 2]: leader imbalance ratio for broker 3 is 0.00 (kafka.controller.KafkaController) [2016-08-17 13:09:50,296] DEBUG [Controller 2]: topics not in preferred replica Map() (kafka.controller.KafkaController) [2016-08-17 13:09:50,297] TRACE [Controller 2]: leader imbalance ratio for broker 4 is 0.

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-17 Thread Mazhar Shaikh
Hi Jun, I'm using default configuration (ack=1), changing it t0 all or 2 will not help, as the producer queue will be exhausted is any kafka broker goes down for long time. Thanks. Regards, Mazhar Shaikh. On Wed, Aug 17, 2016 at 8:11 PM, Jun Rao wrote: > Are you using acks=1 or ack

Re: kafka broker is dropping the messages after acknowledging librdkafka

2016-08-17 Thread Mazhar Shaikh
50,296] TRACE [Controller 2]: leader imbalance ratio for broker 3 is 0.00 (kafka.controller.KafkaController) [2016-08-17 13:09:50,296] DEBUG [Controller 2]: topics not in preferred replica Map() (kafka.controller.KafkaController) [2016-08-17 13:09:50,297] TRACE [Controller 2]: leader imbalance ratio fo

kafka broker is dropping the messages after acknowledging librdkafka

2016-08-10 Thread Mazhar Shaikh
you. Regards Mazhar Shaikh

Kafka 8.2.1 : ISR updation skipped

2015-12-18 Thread Mazhar Shaikh
Can someone please help on this. Thank you. Regards, Mazhar Shaikh.

Error in handling geo redundant kafka process

2015-12-03 Thread Mazhar Shaikh
Hello All, I'm using "librdkafka" for my C Project which has is needed to support geo redundant kafka process (zookeeper + Broker). Machine 1 : Producer1 : Broker IP"sysctrl1.vsepx.broker.com:9092, sysctrl2.vsepx.broker.com:9092" Machine 2 : Broker1 : advertised.host.name=sysctrl1.vsepx.brok