- Fixed
job-name
beingnil
incheck-job
logs - Consumer config accepts any consumer property
- Fixed ArityException introduced in 1.2.6
update-vals
is now inclojure.core
Thread/interrupt
is not exactly the best thing in the world
:message
and:batch
reports now contain:duration
of a call
- Report more data when job is considered dead
- Kafka client version update
- Stop consumer immediately if job fails
- Don't leak job if there is no report yet
- Control batch size in bytes via
:batch-bytes
option
- Feature: job timeout rises up to 10 minutes on each unsuccessfull attempt (by (number of retries)^2)
- Change: job loop logic around stopping job reworked a bit
- Feature: batch processing
- Fix: master thread is a daemon thread (should not prevent JVM from exiting)
- Initial release