Hi Guozhang??
Thank you for your help. I got the reason. I am using logstash to push logs to kafka, and the logstash used an old producer in which messages didn't contain timestamp filed . I should improve logstash-kafka plugin to adapt to the kafka 0.10.0.0. Thank you. ------------------ ???????? ------------------ ??????: "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
