------------------ ???????? ------------------ ??????: "????";<1429327...@qq.com>; ????????: 2016??6??7??(??????) ????11:39 ??????: "users"<users@kafka.apache.org>;
????: ?????? [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp-1 Here are jars I find in kafka libs, it seems nothing wrong. Can you post how you ran the demo? Maybe some problem how I ran it. ------------------ ???????? ------------------ ??????: "Guozhang Wang";<wangg...@gmail.com>; ????????: 2016??6??7??(??????) ????2:52 ??????: "users@kafka.apache.org"<users@kafka.apache.org>; ????: Re: [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp-1 KAFKA-3716 should not be related, as it actually is pointing to a different issue. I re-ran the example demo but could not re-produce your issue. Is it possible that you have multiple Kafka jars in your repo and the older versions were used for the console producer? Guozhang On Sun, Jun 5, 2016 at 6:51 PM, ???? <1429327...@qq.com> wrote: > 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 > -- -- Guozhang
