Normally size is not measured in time unit, such as milliseconds. How about naming the new method segmentInterval ? Thanks -------- Original message --------From: John Roesler <j...@confluent.io> Date: 6/20/18 10:45 AM (GMT-08:00) To: dev@kafka.apache.org Subject: [DISCUSS] KIP-319: Replace segments with segmentSize in WindowBytesStoreSupplier Hello All,
I'd like to propose KIP-319 to fix an issue I identified in KAFKA-7080. Specifically, we're creating CachingWindowStore with the *number of segments* instead of the *segment size*. Here's the jira: https://issues.apache.org/jira/browse/KAFKA-7080 Here's the KIP: https://cwiki.apache.org/confluence/x/mQU0BQ additionally, here's a draft PR for clarity: https://github.com/apache/kafka/pull/5257 Please let me know what you think! Thanks, -John