kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "John Roesler (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-7284) Producer getting fenced may cause Streams to shut down
Date Mon, 13 Aug 2018 20:00:00 GMT
John Roesler created KAFKA-7284:
-----------------------------------

             Summary: 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: Improvement
          Components: streams
    Affects Versions: 2.0.0
            Reporter: John Roesler
            Assignee: John Roesler


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)

Mime
View raw message