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)
