kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "听风" <1429327...@qq.com>
Subject 回复: [Kafka Streams] java.lang.IllegalArgumentException:Invalidtimestamp-1
Date Tue, 07 Jun 2016 03:41:02 GMT
------------------ 原始邮件 ------------------
发件人: "听风";<1429327078@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";<wangguoz@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, 听风 <1429327078@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";<wangguoz@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, 听风 <1429327078@qq.com> wrote:
>
> > Hi Gerard,
> >
> >
> > I use this  version: kafka_2.11-0.10.0.0
> >
> >
> >
> >
> > ------------------ 原始邮件 ------------------
> > 发件人: "Gerard Klijs";<gerard.klijs@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 听风 <1429327078@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
Mime
  • Unnamed multipart/related (inline, 8-Bit, 0 bytes)
View raw message