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)
