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

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

    Error in Kafka Streams using kafka-node - negative timestamp

    Google Groups | 3 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 | 1 month 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 | 1 month 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

  5. 0

    ProcessorTopologyTestDriver Topology Test exception

    Google Groups | 1 month ago | Martin Tyler
    org.apache.kafka.streams.errors.StreamsException: Could not find partition info for topic: test-driver-application-Store1-changelog
  6. 0

    ReduceByKey does not work with topics with > 1 partition.

    GitHub | 1 month ago | jozi-k
    org.apache.kafka.streams.errors.StreamsException: Store Aggregate's change log (aggregation-scala-example-Aggregate-changelog) does not contain partition 1

    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