kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ramanan, Buvana (Nokia - US)" <buvana.rama...@nokia.com>
Subject Invalid TimeStamp Error while running WordCountDemo - kafka-0.10.0
Date Wed, 27 Apr 2016 19:07:22 GMT
Hello,

I am trying to execute WordCountDemo app. I produced text to the input topic. But when I execute
the WordCountDemo, I get error.

please help resolve the following:
ERROR Streams application error during processing in thread [StreamThread-1]:  (org.apache.kafka.streams.processor.internals.StreamThread)
java.lang.IllegalArgumentException: Invalid timestamp -1

broker, consumer & zk are running in the same machine. Ubuntu 14.04, java 1.8.

Thanks,
Buvana

~/kafka-0.10.0/bin$ ./kafka-run-class.sh org.apache.kafka.streams.examples.wordcount.WordCountDemo
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/home/buvana/kafka-0.10.0/core/build/dependant-libs-2.10.6/slf4j-log4j12-1.7.18.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/buvana/kafka-0.10.0/tools/build/dependant-libs-2.10.6/slf4j-log4j12-1.7.18.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/buvana/kafka-0.10.0/connect/api/build/dependant-libs/slf4j-log4j12-1.7.18.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/buvana/kafka-0.10.0/connect/runtime/build/dependant-libs/slf4j-log4j12-1.7.18.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/buvana/kafka-0.10.0/connect/file/build/dependant-libs/slf4j-log4j12-1.7.18.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/buvana/kafka-0.10.0/connect/json/build/dependant-libs/slf4j-log4j12-1.7.18.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
[2016-04-27 14:56:04,967] WARN The configuration replication.factor = 1 was supplied but isn't
a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-27 14:56:04,968] WARN The configuration num.standby.replicas = 0 was supplied but
isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-27 14:56:04,968] WARN The configuration zookeeper.connect = localhost:2181 was supplied
but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-27 14:56:04,968] WARN The configuration __stream.thread.instance__ = Thread[StreamThread-1,5,main]
was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-27 14:56:05,736] ERROR Streams application error during processing in thread [StreamThread-1]:
 (org.apache.kafka.streams.processor.internals.StreamThread)
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:60)
    at org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:331)
    at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:169)
    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:331)
    at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:169)
    at org.apache.kafka.streams.kstream.internals.KStreamAggregate$KStreamAggregateProcessor.process(KStreamAggregate.java:89)
    at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68)
    at org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:331)
    at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:169)
    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:331)
    at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:169)
    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:331)
    at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:169)
    at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:56)
    at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:174)
    at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:350)
    at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:248)



Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message