SAP Knowledge Base Article - Preview

2738133 - kafka adapter error - SAP HANA Streaming Analytics, SAP HANA Smart Data Streaming

Symptom

The below error is reported which states that the producer of the data, e.g. KAFKA JSON output Adapter, is old:

java -cp .
log4j:ERROR setFile(null,true) call failed.
java.io.FileNotFoundException: log/my_kafka.log (No such file or directory)
    at java.io.FileOutputStream.open0(Native Method)
    at java.io.FileOutputStream.open(FileOutputStream.java:270)
    at java.io.FileOutputStream.<init>(FileOutputStream.java:213)
    at java.io.FileOutputStream.<init>(FileOutputStream.java:133)
    at org.apache.log4j.FileAppender.setFile(FileAppender.java:290)
    at org.apache.log4j.RollingFileAppender.setFile(RollingFileAppender.java:194)
    at org.apache.log4j.FileAppender.activateOptions(FileAppender.java:164)
    at org.apache.log4j.config.PropertySetter.activate(PropertySetter.java:257)
    at org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:133)
    at org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:97)
    at org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:689)
    at org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:647)
    at org.apache.log4j.PropertyConfigurator.configureRootCategory(PropertyConfigurator.java:544)
    at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:440)
    at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:476)
    at org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:471)
    at org.apache.log4j.LogManager.<clinit>(LogManager.java:125)
    at org.apache.log4j.Logger.getLogger(Logger.java:118)
    at ...
2018-12-20 16:24:59 INFO  ...:135 - Building stream...
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
...
2018-12-20 16:25:05 ERROR ...:186 - Exception caught in kafka steam while processing data: org.apache.kafka.streams.errors.StreamsException: Input record ConsumerRecord(topic = ..., partition = 1, offset = 626361563, CreateTime = -1, serialized key size = -1, serialized value size = 1779, headers = RecordHeaders(...) has invalid (negative) timestamp. Possibly because a pre-0.10 producer client was used to write this record to Kafka without embedding a timestamp, or because the input topic was created before upgrading the Kafka cluster to 0.10+. Use a different TimestampExtractor to process this data.


Read more...

Environment

  • SAP HANA Smart Data Streaming 1.0
  • SAP HANA Streaming Analytics 2.0

Product

SAP HANA 1.0 smart data streaming ; SAP HANA streaming analytics 2.0

Keywords

negative timestamp, SDS, kafka library libraries, adaptor, stream, processing, processor, 0.10.0.0, 0.9.0.0, jar , KBA , HAN-SDS , SAP HANA Smart Data Streaming , Problem

About this page

This is a preview of a SAP Knowledge Base Article. Click more to access the full version on SAP ONE Support launchpad (Login required).

Search for additional results

Visit SAP Support Portal's SAP Notes and KBA Search.