Re: Lock Exception - Failed to lock the state directory

In case you use 0.10.0.2 please have a look into this FAQ https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Igetalockingexceptionsimilarto"Causedby:java.io.IOException:Failedtolockthestatedirectory:/tmp/kafka-streams//0_0".HowcanIresolvethis? However, if possible I would recommend to upgr

Re: Lock Exception - Failed to lock the state directory

Hi Dan, Just checking on the version: you are using 0.10.0.2 or 0.10.2.0 (i.e., latest)? I ask because state locking was something that was fixed in 0.10.2. Thanks Eno > On 26 Feb 2017, at 13:37, Dan Ofir wrote: > > Hi, > > I encountered an exception while using kafka stream, which I cannot

Lock Exception - Failed to lock the state directory

Hi, I encountered an exception while using kafka stream, which I cannot find any open bug or any related documentations. I am using Kafka stream 0.10.0.2, with 3 nodes kafka server running also 0.10.0.2. I am trying to process huge amount of data ~24800 events. my input topic have 100 partit