- Improve the performance of persisting kafka messages if the local store cannot perform frequent file appends and causing high I/O issues - Switching from `jsonpath-ng` to `dpath` python library to improve the performance of extracting primary keys - Change the syntax of `primary_keys` from JSONPath to `/slashed/paths` ala XPath
3.1.0
-------------------
- Add `max_poll_records` option
3.0.0
-------------------
- Add local storage of consumed messages and instant commit kafka offsets - Add more configurable options: `consumer_timeout_ms`, `session_timeout_ms`, `heartbeat_interval_ms`, `max_poll_interval_ms` - Add two new fixed output columns: `MESSAGE_PARTITION` and `MESSAGE_OFFSET`
2.1.1
-------------------
- Commit offset from state file and not from the consumed messages
2.1.0
-------------------
- Make logging customisable
2.0.0
-------------------
- Rewamp the output schema with no JSON flattening