Re: Reinstating ephemeral nodes and watchers on zk session timeout

Here are the remaining issuesstill in progress. I believe we should be able to do a release mid April. Thanks, Neha On Tue, Mar 25, 2014 at 10:28 AM, Bae

Re: Reinstating ephemeral nodes and watchers on zk session timeout

Do you have any ETA for 0.8.1.1? On Tue, Mar 25, 2014 at 9:53 AM, Neha Narkhede wrote: > You are probably hitting https://issues.apache.org/jira/browse/KAFKA-1317. > We are trying to fix it in time for 0.8.1.1. > > Thanks, > Neha > > > On Tue, Mar 25, 2014 at 9:45 AM, Bae, Jae Hyeon > wrote: >

Re: Reinstating ephemeral nodes and watchers on zk session timeout

You are probably hitting https://issues.apache.org/jira/browse/KAFKA-1317. We are trying to fix it in time for 0.8.1.1. Thanks, Neha On Tue, Mar 25, 2014 at 9:45 AM, Bae, Jae Hyeon wrote: > ZkEventThread is blocked with the following stack trace: > > "ZkClient-EventThread-18-localhost:2181" da

Re: Reinstating ephemeral nodes and watchers on zk session timeout

ZkEventThread is blocked with the following stack trace: "ZkClient-EventThread-18-localhost:2181" daemon prio=5 tid=7fb31b95c000 nid=0x1194a6000 waiting on condition [1194a5000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <7c220180

Re: Reinstating ephemeral nodes and watchers on zk session timeout

Nope, linux doesn't work. Let me debug why it's not triggered. On Tue, Mar 25, 2014 at 9:21 AM, Bae, Jae Hyeon wrote: > Hm... I cannot reproduce in my local, I downloaded kafka_2.8.0-0.8.1 > package but it didn't work. Let me try in my linux machine. > > > On Mon, Mar 24, 2014 at 6:11 PM, Neha

Re: Reinstating ephemeral nodes and watchers on zk session timeout

Hm... I cannot reproduce in my local, I downloaded kafka_2.8.0-0.8.1 package but it didn't work. Let me try in my linux machine. On Mon, Mar 24, 2014 at 6:11 PM, Neha Narkhede wrote: > I think you are trying to introduce a session expiration, then could you > try to do the following and see if y

Re: Reinstating ephemeral nodes and watchers on zk session timeout

I think you are trying to introduce a session expiration, then could you try to do the following and see if you can reproduce the session expiration? ./bin/kafka-server-start.sh config/server.properties kill -SIGSTOP sleep 6s At this point, the session will be expired and the node will disappear

Reinstating ephemeral nodes and watchers on zk session timeout

Hi On zookeeper session timeout due to some stopping the world long GC pause or zookeeper server outage, Ephemeral nodes on kafka broker and consumer should be recreated but in my test environment, handleNewSession() is not called. My test scenario is, starting kafka broker locally and put a brea