org.apache.kafka.streams.errors.StreamsException: Extracted timestamp value is negative, which is not allowed.

Google Groups | Martin Tyler | 4 months ago
  1. 0

    Error in Kafka Streams using kafka-node - negative timestamp

    Google Groups | 4 months ago | Martin Tyler
    org.apache.kafka.streams.errors.StreamsException: Extracted timestamp value is negative, which is not allowed.
  2. 0

    ProcessorTopologyTestDriver not working with KTable

    Google Groups | 3 months ago | Byron N
    org.apache.kafka.streams.errors.StreamsException: task [0_0] Could not find partition info for topic: test
  3. 0

    ProcessorTopologyTestDriver Topology Test exception

    Google Groups | 3 months ago | Martin Tyler
    org.apache.kafka.streams.errors.StreamsException: Could not find partition info for topic: test-driver-application-Store1-changelog
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. org.apache.kafka.streams.errors.StreamsException

      Extracted timestamp value is negative, which is not allowed.

      at org.apache.kafka.streams.processor.internals.RecordQueue.addRawRecords()
    2. org.apache.kafka
      StreamThread.run
      1. org.apache.kafka.streams.processor.internals.RecordQueue.addRawRecords(RecordQueue.java:90)
      2. org.apache.kafka.streams.processor.internals.PartitionGroup.addRawRecords(PartitionGroup.java:117)
      3. org.apache.kafka.streams.processor.internals.StreamTask.addRecords(StreamTask.java:138)
      4. org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:304)
      5. org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218)
      5 frames