Aiokafka

==================

New features:

* Add full support for V2 format messages with a Cython extension. Those are
used for Kafka >= 0.11.0.0
* Added support for transactional producing (issue 182)
* Added support for idempotent producing with `enable_idempotence` parameter
* Added support for `fetch_max_bytes` in AIOKafkaConsumer. This can help limit
the amount of data transferred in a single roundtrip to broker, which is
essential for consumers with large amount of partitions

Bugfixes:

* Fix issue with connections not propagating serialization errors
* Fix issue with `group=None` resetting offsets on every metadata update
(issue 441)
* Fix issue with messages not delivered in order when Leader changes (issue
228)
* Fixed version parsing of `api_version` parameter. Before it ignored the
parameter

==================

Bugfix:

* Fixed memory issue introduced as a result of a bug in `asyncio.shield` and
not cancelling coroutine after usage. (see issue 444 and 436)

==================

Bugfix:

* Added error propagation from coordinator to main consumer. Before consumer
just stopped with error logged. (issue 294)
* Fix manual partition assignment, broken in 0.4.0 (issue 394)
* Fixed RecursionError in MessageAccumulator.add_message (issue 409)
* Update kafka-python to latest 1.4.3 and added support for Python3.7
* Dropped support for Python3.3 and Python3.4

Infrastructure:

* Added Kafka 1.0.2 broker for CI test runner
* Refactored travis CI build pipeline

==================

* Fix issue when offset commit error reports wrong partition in log (issue 353)
* Add ResourceWarning when Producer, Consumer or Connections are not closed
properly (issue 295)
* Fix Subscription None in GroupCoordinator._do_group_rejoin (issue 306)

==================

Major changes:

* Full refactor of the internals of AIOKafkaConsumer. Needed to avoid several
race conditions in code (PR 286, fixes 258, 264 and 261)
* Rewrote Records parsing protocol to allow implementation of newer protocol
versions later
* Added C extension for Records parsing protocol, boosting the speed of
produce/consume routines significantly
* Added an experimental batch producer API for unique cases, where user wants
to control batching himself (by shargan)


Minor changes:

* Add `timestamp` field to produced message's metadata. This is needed to find
LOG_APPEND_TIME configured timestamps.
* `Consumer.seek()` and similar API's now raise proper ``ValueError``'s on
validation failure instead of ``AssertionError``.


Bug fixes:

* Fix ``connections_max_idle_ms`` option, as earlier it was only applied to
bootstrap socket. (PR 299)
* Fix ``consumer.stop()`` side effect of logging an exception
ConsumerStoppedError (issue 263)
* Problem with Producer not able to recover from broker failure (issue 267)
* Traceback containing duplicate entries due to exception sharing (PR 247
by Artimi)
* Concurrent record consumption rasing `InvalidStateError('Exception is not
set.')` (PR 249 by aerkert)
* Don't fail ``GroupCoordinator._on_join_prepare()`` if ``commit_offset()``
throws exception (PR 230 by shargan)
* Send session_timeout_ms to GroupCoordinator constructor (PR 229 by shargan)

Big thanks to:

* shargan for Producer speed enhancements and the batch produce API
proposal/implementation.
* vineet-rh and other contributors for constant feedback on Consumer
problems, leading to the refactor mentioned above.

==================

* Added `AIOKafkaProducer.flush()` method. (PR 209 by vineet-rh)
* Fixed a bug with uvloop involving `float("inf")` for timeout. (PR 210 by
dmitry-moroz)
* Changed test runner to allow running tests on OSX. (PR 213 by shargan)