[ https://issues.apache.org/jira/browse/KAFKA-9012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948392#comment-16948392 ]
panpan.liu commented on KAFKA-9012: ----------------------------------- It is difficult to reproduce this exception. How to reproduce the exception manually ? > 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 > Priority: Major > > kafka broker: 2.0.0 > kafka stream 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)