You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "John Roesler (JIRA)" <ji...@apache.org> on 2018/10/03 20:18:00 UTC

[jira] [Created] (KAFKA-7477) Improve Streams close timeout semantics

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
(v7.6.3#76005)