[jira] [Created] (KAFKA-9012) OutOfOrderSequenceException occurred, all stream stopped consuming

["panpan.liu (Jira)" <ji...@apache.org>]

panpan.liu created KAFKA-9012:
---------------------------------

             Summary: OutOfOrderSequenceException occurred, all stream stopped consuming
                 Key: KAFKA-9012
                 URL: https://issues.apache.org/jira/browse/KAFKA-9012
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 2.0.0
            Reporter: panpan.liu


kafka broker: 2.0.0

kafka client version: 2.0.1

```

2019-10-08 16:42:24.564|ERROR|kafka-producer-network-thread | flash-client-bch-StreamThread-10-3_1-producer|o.a.k.s.p.i.RecordCollectorImpl|131|task [3_1] Error sending record (key shrenujmilak.jmda value WorkerMiningDataSummary(userWorkerId=shrenujmilak.jmda, userId=339307, share1Count=688128, stale1Count=0, dupe1Count=0, other1Count=0, createTime=1570552932000) timestamp 1570552932000) to topic flash-app-bch-worker-share-store-day-repartition due to org.apache.kafka.common.errors.OutOfOrderSequenceException: The broker received an out of order sequence number.; No more records will be sent and no more offsets will be recorded for this task.

```

 

 

```

2019-10-08 16:42:25.218|ERROR|flash-client-bch-StreamThread-10|o.a.k.s.p.i.AssignedStreamsTasks|117|stream-thread [flash-client-bch-StreamThread-10] Failed to process stream task 3_1 due to the following error:
org.apache.kafka.streams.errors.StreamsException: Exception caught in process. taskId=3_1, processor=KSTREAM-SOURCE-0000000016, topic=bch-worker-benchmark-share, partition=1, offset=95860323
 at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:367)
Caused by: org.apache.kafka.streams.errors.StreamsException: task [3_1] Abort sending since an error caught with a previous record (key shrenujmilak.jmda value WorkerMiningDataSummary(userWorkerId=shrenujmilak.jmda, userId=339307, share1Count=688128, stale1Count=0, dupe1Count=0, other1Count=0, createTime=1570552932000) timestamp 1570552932000) to topic flash-app-bch-worker-share-store-day-repartition due to org.apache.kafka.common.errors.OutOfOrderSequenceException: The broker received an out of order sequence number.
 at org.apache.kafka.streams.processor.internals.RecordCollectorImpl.recordSendError(RecordCollectorImpl.java:133)
Caused by: org.apache.kafka.common.errors.OutOfOrderSequenceException: The broker received an out of order sequence number.
2019-10-08 16:42:25.222|INFO |flash-client-bch-StreamThread-10|o.a.k.s.p.i.StreamThread|207|stream-thread [flash-client-bch-StreamThread-10] State transition from RUNNING to PENDING_SHUTDOWN
2019-10-08 16:42:25.226|INFO |flash-client-bch-StreamThread-10|o.a.k.s.p.i.StreamThread|1178|stream-thread [flash-client-bch-StreamThread-10] Shutting down

```



--
This message was sent by Atlassian Jira
(v8.3.4#803005)