Re: Shell scripts for Windows corrected

2014-04-02 Thread Jun Rao
No, since the patch in KAFKA-1230 no longer applies to trunk. Could you provide a new patch? Thanks, Jun On Wed, Apr 2, 2014 at 11:14 AM, John Arnold (GNS) wrote: > Did this ever get fixed? The windows scripts are still under /bin/windows > instead of just /bin, and I can't get them to work p

Re: kafka availability

2014-04-02 Thread Jun Rao
bin/kafka-topics.sh --zookeeper zookeeper1 --topic test.app4 --describe Topic:test.app4PartitionCount:1ReplicationFactor:2Configs: Topic: test.app4Partition: 0Leader: 1Replicas: 1,0Isr: 1 Is broker 0 up when you did the above? Normally, when both brokers are up, isr

Re: Controlled shutdown and leader election issues

2014-04-02 Thread Neha Narkhede
I'm not so sure if I know the issue you are running into but we fixed a few bugs with similar symptoms and the fixes are on the 0.8.1 branch. It will be great if you give it a try to see if your issue is resolved. Thanks, Neha On Wed, Apr 2, 2014 at 12:59 PM, Clark Breyman wrote: > Was there a

Re: NullPointerException in broker on notification of ZK session end

2014-04-02 Thread Clark Breyman
Thanks Tim. On Wed, Apr 2, 2014 at 5:18 PM, Timothy Chen wrote: > Hey Clark, > > Small world indeed :) > > I don't believe it's associated with KAFKA-1310, and I actually > already have a fix in the 0.8.1 branch and trunk. Please try it and it > will be in our 0.8.1.1 release. > > I can actuall

Re: NullPointerException in broker on notification of ZK session end

2014-04-02 Thread Timothy Chen
Hey Clark, Small world indeed :) I don't believe it's associated with KAFKA-1310, and I actually already have a fix in the 0.8.1 branch and trunk. Please try it and it will be in our 0.8.1.1 release. I can actually repro the problem you're seeing, seems like we're calling onControllerResignation

Re: NullPointerException in broker on notification of ZK session end

2014-04-02 Thread Clark Breyman
Tim - Actually I was looking at the wrong commit (0.8.1 has 0.8.1.1 commits in it). The 0.8.1.0 tag has deleteTopicManager.shutdown() on KafkaController.scala:340. Not sure how deleteTopicManager can skip initialization. On Wed, Apr 2, 2014 at 4:00 PM, Clark Breyman wrote: > Hey Tim. Small worl

Re: NullPointerException in broker on notification of ZK session end

2014-04-02 Thread Clark Breyman
Hey Tim. Small world :). Kafka 0.8.1_2.10 On Wed, Apr 2, 2014 at 3:54 PM, Timothy Chen wrote: > Hi Clark, > > What version of Kafka are you running this from? > > Thanks, > > Tim > > > On Wed, Apr 2, 2014 at 3:49 PM, Clark Breyman wrote: > > > I'm seeing a lot of this in my logs on a non-co

Re: NullPointerException in broker on notification of ZK session end

2014-04-02 Thread Timothy Chen
Hi Clark, What version of Kafka are you running this from? Thanks, Tim On Wed, Apr 2, 2014 at 3:49 PM, Clark Breyman wrote: > I'm seeing a lot of this in my logs on a non-controller broker: > > 2014-04-02 15:42:23,078] ERROR Error handling event ZkEvent[New session > event sent to > kafka.co

NullPointerException in broker on notification of ZK session end

2014-04-02 Thread Clark Breyman
I'm seeing a lot of this in my logs on a non-controller broker: 2014-04-02 15:42:23,078] ERROR Error handling event ZkEvent[New session event sent to kafka.controller.KafkaController$SessionExpirationListener@204a18ac] (org.I0Itec.zkclient.ZkEventThread) java.lang.NullPointerException at kafka.con

Re: Controlled shutdown and leader election issues

2014-04-02 Thread Clark Breyman
Was there an answer for 0.8.1 getting stuck in preferred leader election? I'm seeing this as well. Is there a JIRA ticket on this issue? On Fri, Mar 21, 2014 at 1:15 PM, Ryan Berdeen wrote: > So, for 0.8 without "controlled.shutdown.enable", why would ShutdownBroker > and restarting cause under

RE: Shell scripts for Windows corrected

2014-04-02 Thread John Arnold (GNS)
Did this ever get fixed? The windows scripts are still under /bin/windows instead of just /bin, and I can't get them to work properly. Thanks, John

Re: Kafka and authentication

2014-04-02 Thread Joe Stein
Hi Raja, do you have an ICLA https://www.apache.org/licenses/icla.txt on file with Apache? One thought would be to branch a security branch at the commit you forked from. Then treat the rest of your commits as a contrib patch (requires vote). Then we could work on merging it into upstream and kn

kafka availability

2014-04-02 Thread Anatoly Deyneka
Hi, I perform availability tests on next kafka setup: - 3 nodes(2f+1) for zookeeper(zookeeper1, zookeeper2, zookeeper3) - 2 nodes(f+1) for kafka brokers(id:0,host:kafka.broker1,port:9092; id:1,host:kafka.broker2,port:9092) I use java producer and console consumer. Test stepts: 1. create topic tes