Hi Guozhang,
YES. the console producer, broker, and kafka streams are all 0.10.0.0 version. is it because of this bug ? https://issues.apache.org/jira/browse/KAFKA-3716?jql=project%20%3D%20KAFKA ------------------ ???????? ------------------ ??????: "Guozhang Wang";<wangg...@gmail.com>; ????????: 2016??6??4??(??????) ????2:25 ??????: "users@kafka.apache.org"<users@kafka.apache.org>; ????: Re: [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp -1 Hello, Did you mean that the console producer, broker, and kafka streams are all using 0.10.0.0 version? Guozhang On Fri, Jun 3, 2016 at 1:35 AM, ???? <1429327...@qq.com> wrote: > Hi Gerard?? > > > I use this version: kafka_2.11-0.10.0.0 > > > > > ------------------ ???????? ------------------ > ??????: "Gerard Klijs";<gerard.kl...@dizzit.com>; > ????????: 2016??6??3??(??????) ????4:31 > ??????: "users"<users@kafka.apache.org>; > > ????: Re: [Kafka Streams] java.lang.IllegalArgumentException: > Invalidtimestamp -1 > > > > First thing which comes to my mind, did you use it on a new kafka (broker) > version? Streams don't work with older brokers. > > On Fri, Jun 3, 2016 at 9:15 AM ???? <1429327...@qq.com> wrote: > > > Hello?? > > > > > > Can someone give me a hand? > > > > > > version: kafka_2.11-0.10.0.0 > > > > > > Run kafka strams application WordCountDemo, got erro?? > > > > > > ERROR Streams application error during processing in thread > > [StreamThread-1]: > > (org.apache.kafka.streams.processor.internals.StreamThread:225) > > java.lang.IllegalArgumentException: Invalid timestamp -1 > > at > > > org.apache.kafka.clients.producer.ProducerRecord.<init>(ProducerRecord.java:60) > > at > > > org.apache.kafka.streams.processor.internals.SinkNode.process(SinkNode.java:72) > > at > > > org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187) > > at > > > org.apache.kafka.streams.kstream.internals.KStreamMapValues$KStreamMapProcessor.process(KStreamMapValues.java:42) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68) > > at > > > org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187) > > at > > > org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateProcessor.process(KStreamAggregate.java:92) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68) > > at > > > org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187) > > at > > > org.apache.kafka.streams.kstream.internals.KStreamMap$KStreamMapProcessor.process(KStreamMap.java:43) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68) > > at > > > org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187) > > at > > > org.apache.kafka.streams.kstream.internals.KStreamFlatMapValues$KStreamFlatMapValuesProcessor.process(KStreamFlatMapValues.java:43) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68) > > at > > > org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338) > > at > > > org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187) > > at > > > org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:64) > > at > > > org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:174) > > at > > > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:320) > > at > > > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218) > -- -- Guozhang
