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 Fri, 03 Jun 2016 08:35:28 GMT
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)
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message