You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by 听风 <14...@qq.com> on 2016/06/06 01:51:50 UTC
回复： [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp -1
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";<wa...@gmail.com>;
发送时间: 2016年6月4日(星期六) 凌晨2:25
收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@qq.com> wrote:
> Hi Gerard，
>
>
> I use this version: kafka_2.11-0.10.0.0
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "Gerard Klijs";<ge...@dizzit.com>;
> 发送时间: 2016年6月3日(星期五) 下午4:31
> 收件人: "users"<us...@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 听风 <14...@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
回复： [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp-1
Posted by 听风 <14...@qq.com>.
------------------ 原始邮件 ------------------
发件人: "听风";<14...@qq.com>;
发送时间: 2016年6月7日(星期二) 中午11:39
收件人: "users"<us...@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";<wa...@gmail.com>;
发送时间: 2016年6月7日(星期二) 凌晨2:52
收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@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";<wa...@gmail.com>;
> 发送时间: 2016年6月4日(星期六) 凌晨2:25
> 收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@qq.com> wrote:
>
> > Hi Gerard，
> >
> >
> > I use this version: kafka_2.11-0.10.0.0
> >
> >
> >
> >
> > ------------------ 原始邮件 ------------------
> > 发件人: "Gerard Klijs";<ge...@dizzit.com>;
> > 发送时间: 2016年6月3日(星期五) 下午4:31
> > 收件人: "users"<us...@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 听风 <14...@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
回复： [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp-1
Posted by 听风 <14...@qq.com>.
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";<wa...@gmail.com>;
发送时间: 2016年6月7日(星期二) 凌晨2:52
收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@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";<wa...@gmail.com>;
> 发送时间: 2016年6月4日(星期六) 凌晨2:25
> 收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@qq.com> wrote:
>
> > Hi Gerard，
> >
> >
> > I use this version: kafka_2.11-0.10.0.0
> >
> >
> >
> >
> > ------------------ 原始邮件 ------------------
> > 发件人: "Gerard Klijs";<ge...@dizzit.com>;
> > 发送时间: 2016年6月3日(星期五) 下午4:31
> > 收件人: "users"<us...@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 听风 <14...@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
回复： [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp-1
Posted by 听风 <14...@qq.com>.
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";<wa...@gmail.com>;
发送时间: 2016年6月7日(星期二) 凌晨2:52
收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@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";<wa...@gmail.com>;
> 发送时间: 2016年6月4日(星期六) 凌晨2:25
> 收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@qq.com> wrote:
>
> > Hi Gerard，
> >
> >
> > I use this version: kafka_2.11-0.10.0.0
> >
> >
> >
> >
> > ------------------ 原始邮件 ------------------
> > 发件人: "Gerard Klijs";<ge...@dizzit.com>;
> > 发送时间: 2016年6月3日(星期五) 下午4:31
> > 收件人: "users"<us...@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 听风 <14...@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
Re: [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp
-1
Posted by Guozhang Wang <wa...@gmail.com>.
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, 听风 <14...@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";<wa...@gmail.com>;
> 发送时间: 2016年6月4日(星期六) 凌晨2:25
> 收件人: "users@kafka.apache.org"<us...@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, 听风 <14...@qq.com> wrote:
>
> > Hi Gerard，
> >
> >
> > I use this version: kafka_2.11-0.10.0.0
> >
> >
> >
> >
> > ------------------ 原始邮件 ------------------
> > 发件人: "Gerard Klijs";<ge...@dizzit.com>;
> > 发送时间: 2016年6月3日(星期五) 下午4:31
> > 收件人: "users"<us...@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 听风 <14...@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