[
https://issues.apache.org/jira/browse/KAFKA-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-7284:
-----------------------------------
Fix Version/s: 1.1.2
> Producer getting fenced may cause Streams to shut down
> ------------------------------------------------------
>
> Key: KAFKA-7284
> URL: https://issues.apache.org/jira/browse/KAFKA-7284
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 0.11.0.3, 1.0.2, 1.1.1, 2.0.0
> Reporter: John Roesler
> Assignee: John Roesler
> Priority: Critical
> Fix For: 1.1.2, 2.0.1, 2.1.0
>
>
> As part of the investigation, I will determine what other versions are
> affected.
>
> In StreamTask, we catch a `ProducerFencedException` and throw a
> `TaskMigratedException`. However, in this case, the `RecordCollectorImpl` is
> throwing a `StreamsException`, caused by `KafkaException` caused by
> `ProducerFencedException`.
> In response to a TaskMigratedException, we would rebalance, but when we get a
> StreamsException, streams shuts itself down.
> In other words, we intended to do a rebalance in response to a producer
> fence, but actually, we shut down (when the fence happens inside the record
> collector).
> Coincidentally, Guozhang noticed and fixed this in a recent PR:
> [https://github.com/apache/kafka/pull/5428/files#diff-4e5612eeba09dabf30d0b8430f269ff6]
>
> The scope of this ticket is to extract that fix and associated tests, and
> send a separate PR to trunk and 2.0, and also to determine what other
> versions, if any, are affected.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
