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)

Reply via email to