Hi Mathieu, What version of Kafka are you using? There was recently a fix that went into trunk, just checking if you're using an older version. (to make forward progress you can turn the cache off, like this: streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0); )
Thanks Eno > On 4 Dec 2016, at 03:47, Mathieu Fenniak <mathieu.fenn...@replicon.com> wrote: > > Hey all, > > I've just been running a quick test of my kafka-streams application on the > latest Kafka trunk (@e43bbce), and came across this error. I was wondering > if anyone has seen this error before, have any thoughts on what might cause > it, or can suggest a direction to investigate it further. > > Full exception: > https://gist.github.com/mfenniak/509fb82dfcfda79a21cfc1b07dafa89c > > java.lang.IllegalStateException: Attempting to put a clean entry for key > [urn:replicon-tenant:strprc971e3ca9:timesheet:97c0ce25-e039-4e8b-9f2c-d43f0668b755] > into NamedCache [0_0-TimesheetNonBillableHours] when it already contains a > dirty entry for the same key > at > org.apache.kafka.streams.state.internals.NamedCache.put(NamedCache.java:124) > at > org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:120) > at > org.apache.kafka.streams.state.internals.CachingKeyValueStore.get(CachingKeyValueStore.java:146) > at > org.apache.kafka.streams.state.internals.CachingKeyValueStore.get(CachingKeyValueStore.java:133) > at > org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateValueGetter.get(KTableAggregate.java:128) > at > org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:81) > at > org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:54) > at > org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) > ... more ...
