You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2017/10/25 23:50:00 UTC

[jira] [Created] (KAFKA-6126) Reduce rebalance time by not checking if created topics are available

Matthias J. Sax created KAFKA-6126:
--------------------------------------

             Summary: Reduce rebalance time by not checking if created topics are available
                 Key: KAFKA-6126
                 URL: https://issues.apache.org/jira/browse/KAFKA-6126
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 1.0.0
            Reporter: Matthias J. Sax
             Fix For: 1.1.0


Within {{StreamPartitionAssignor#assign}} we create new topics and afterwards wait in an "infinite loop" until topic metadata propagated throughout the cluster. We do this, to make sure topics are available when we start processing.

However, with this approach we "extend" the time in the rebalance phase and thus are not responsive (no calls to `poll` for liveness check and {{KafkaStreams#close}} suffers). Thus, we might want to remove this check and handle potential "topic not found" exceptions in the main thread gracefully.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)