[
https://issues.apache.org/jira/browse/KAFKA-9012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
panpan.liu updated KAFKA-9012:
------------------------------
Description:
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
```
was:
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
```
> 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)
