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-7477) Improve Streams close timeout semantics
Date Wed, 03 Oct 2018 20:18:00 GMT
John Roesler created KAFKA-7477:

             Summary: Improve Streams close timeout semantics
                 Key: KAFKA-7477
                 URL: https://issues.apache.org/jira/browse/KAFKA-7477
             Project: Kafka
          Issue Type: Improvement
          Components: streams
            Reporter: John Roesler

See [https://github.com/apache/kafka/pull/5682#discussion_r221473451]

The current timeout semantics are a little "magical":
 * 0 means to block forever
 * negative numbers cause the close to complete immediately without checking the state

I think this would make more sense:
 * reject negative numbers
 * make 0 just signal and return immediately (after checking the state once)
 * if I want to wait "forever", I can use {{ofYears(1)}} or {{ofMillis(Long.MAX_VALUE)}} or
some other intuitively "long enough to be forever" value instead of a magic value.

This message was sent by Atlassian JIRA

View raw message