- Defensively reduce chances of deadlock.
- Fixed typo in README
- Add :kafka/wrap-with-metadata? input task-map option.
- Fixed issue where exception was not passed back from the kafka reader thread to read-batch. This meant that peers could become zombies and stop reading from the topic.
Support auto-assigned partitions.
- BREAKING CHANGE write-messages now takes segments in the form
{:message message-body}
or{:message message-body :key message-key}
. - Embedded Kafka server and take-segments test utils function are now included