[KAFKA-7446] Better error message to explain the upper limit of TimeWindow

• Type: Improvement
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.2.0
• Component/s: streams
• Labels: newbie++
• Assignee: Srinivas Reddy
• Reporter: Jacek Laskowski
• Created: 27/Sep/18 09:33
• Updated: 04/Dec/18 07:03
• Resolved: 04/Dec/18 07:03

Description

The following code throws a IllegalArgumentException.

import org.apache.kafka.streams.kstream.TimeWindows
import scala.concurrent.duration._
val timeWindow = TimeWindows
.of(1.minute.toMillis)
.advanceBy(2.minutes.toMillis)

The exception is as follows and it's not clear why 60000 is the upper limit (not to mention that AdvanceMs with the uppercase A did also confuse me).

java.lang.IllegalArgumentException: AdvanceMs must lie within interval (0, 60000].
at org.apache.kafka.streams.kstream.TimeWindows.advanceBy(TimeWindows.java:100)
... 44 elided

I think that the message should be more developer-friendly and explain the boundaries, perhaps with an example (and a link to docs)?

Issue Links

• links to: GitHub Pull Request #5930