Eugene R.

Please make sure you build with JDK 11 or above. See open issue #11.

@flozano please see v0.3.1 installation instructions.

It is possible to implement shared blocks such as Throttler and windows. It is better to make them modular so that more storage systems can be added. It would be...

The original Java Quartz throws an exception on a duplicate job being scheduled. The current architecture would require a full scan of all scheduled jobs to detect duplicates, which is...

Yes, this one would work, but it's odd and wrong to have this functionality hidden from the user. In the meantime, the only error returned is the "No Job found"...

@kusurov, you can turn logs off using ```go func init() { log.SetOutput(ioutil.Discard) } ```

The scheduler uses a channel to schedule the job, which causes the linger you've spotted. To solve the case the architecture might need to be revisited along with other scheduling-related...

A logger interface has been added in #67.

Closing due to inactivity.

You're right, stream partitioning is not implemented yet. There are several utility methods available [here](https://github.com/reugn/go-streams/blob/v0.10.0/flow/util.go), but they may not be suitable for your specific requirements.