question about isr

2014-04-24 Thread
Hi Team, I found a strange phenomenon of isr list in my kafka cluster When I use the tool that kafka provide to get the topic information, and it show isr list as following, seem it is ok [irt...@xseed171.kdev bin]$ ./kafka-topics.sh --describe --zookeeper

Re: question about isr

2014-04-24 Thread
-Original Message- From: Jun Raolt;jun...@gmail.comgt; To: users@kafka.apache.orglt;users@kafka.apache.orggt;; 陈小军lt;chenxiao...@nhn.comgt;; Cc: Sent: 2014-04-25 (星期五) 02:12:02 Subject: Re: question about isr Interesting. Which version of Kafka are you using? Were you doing some partition

send snappy log got java.lang.NoClassDefFoundError:

2014-04-08 Thread
Hi all, I try to add compress feature on kafka-node js driver, for snappy I use node-snappy library https://github.com/kesla/node-snappy. when I test my code, the server always output following error, I don't know this is my code error, or server side compatible problem. I use

Re: send snappy log got java.lang.NoClassDefFoundError:

2014-04-08 Thread
Thanks, it is libstdc++ compatible problem, I recompile the library, and it works. Best Regards Jerry -Original Message- From: Bae, Jae Hyeonlt;metac...@gmail.comgt; To: users@kafka.apache.orglt;users@kafka.apache.orggt;; 陈小军lt;chenxiao...@nhn.comgt;; Cc: Sent: 2014-04-08 (星期二

Re: dynamic configure per topic problem

2014-03-25 Thread
Thanks. I got it.Best RegardsJerry-Original Message-From: "Neha Narkhede"neha.narkh...@gmail.com To: "users@kafka.apache.org"users@kafka.apache.org; Cc: "陈小军"chenxiao...@nhn.com; Sent: 2014-03-26 (星期三) 02:08:46Subject: Re: dynamic configure per topic problemF

RE: Fwd: When running kafka-preferred kafka-preferred-replica-election.sh for a second time a node exists exception is being thrown

2014-03-24 Thread
Yes, I also have this problem using 0.8.1. if you want second time is works, I always manual delete the node in zookeeper Best Regards Jerry -Original Message- From: Chris Georgelt;ch...@htmlcreators.comgt; To: lt;users@kafka.apache.orggt;; Cc: Sent: 2014-03-25 (星期二) 05:03:22 Subject:

zookeeper exception

2014-03-13 Thread
Hi all i use 0.8.1 release to do test, and get following error logs [hadoop@nelo76 libs]$ [2014-03-14 12:11:44,310] INFO Partition [nelo2-normal-logs,0] on broker 0: Shrinking ISR for partition [nelo2-normal-logs,0] from 0,1 to 0 (kafka.cluster.Partition) [2014-03-14 12:11:44,313]

kafka leader automatic changed

2014-02-17 Thread
Hi, I running kafka 0.8.1 branch code. in my test env, I have 3 servers (broker 1, 2, 3), and create three topics with 3 partitions and 2 replica for each partition. at beginning each partition's leader is allocated to different server. topicA : partition 0 --gt; leader : 1; partition 1

RE: kafka leader automatic changed

2014-02-17 Thread
(kafka.server.ZookeeperLeaderElector) [2014-02-18 00:27:55,882] INFO New leader is 2 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener) Best Regards Jerry -Original Message- From: 陈小军lt;chenxiao...@nhn.comgt; To: lt;users@kafka.apache.orggt;; Cc: Sent: 2014-02-18 (星期二) 10:41:00 Subject: kafka leader

Re: Kafka server occure java.nio.BufferUnderflowException

2014-01-22 Thread
I use c library (librdkafka) Best Regards Jerry -Original Message- From: Jun Raolt;jun...@gmail.comgt; To: users@kafka.apache.orglt;users@kafka.apache.orggt;; 陈小军lt;chenxiao...@nhn.comgt;; Cc: Sent: 2014-01-22 (星期三) 00:44:59 Subject: Re: Kafka server occure

kafka performance test

2014-01-15 Thread
I was just reading this:https://cwiki.apache.org/confluence/display/KAFKA/Performance+testingHas this been implemented yet? I can't seem tofind it in the source. Best Regards Jerry

Re: kafka server crash when I insert the data

2013-12-26 Thread
I use the librdkafka, a c libray of Kafka. https://github.com/edenhill/librdkafka maybe there is1k logs/second. Best Regards Jerry -Original Message- From: Guozhang Wanglt;wangg...@gmail.comgt; To: users@kafka.apache.orglt;users@kafka.apache.orggt;; 陈小军lt;chenxiao...@nhn.comgt;; Cc

RE: Logs and distributed systems

2013-12-17 Thread
Thanks for sharing. Best Regards Jerry -Original Message- From: Jay Krepslt;jay.kr...@gmail.comgt; To: users@kafka.apache.orglt;users@kafka.apache.orggt;; lt;d...@samza.incubator.apache.orggt;; Cc: Sent: 2013-12-17 (星期二) 06:00:17 Subject: Logs and distributed systems For anyone