f7368ad3dd
1.4.4: Bugfixes * (Attempt to) Fix deadlock between consumer and heartbeat * Fix Metrics dict memory leak Client * Support Kafka record headers * Set socket timeout for the write-side of wake socketpair * Add kerberos domain name config for gssapi sasl mechanism handshake * Support smaller topic metadata fetch during bootstrap * Use TypeError for invalid timeout type * Break poll if closed Admin Client * Add KafkaAdminClient class * Fix list_consumer_groups() to query all brokers * Stop using broker-errors for client-side problems * Fix send to controller * Add group coordinator lookup * Fix describe_groups * Add list_consumer_group_offsets() * Remove support for api versions as strings from KafkaAdminClient * Set a clear default value for validate_only/include_synonyms * Bugfix: Always set this_groups_coordinator_id Consumer * Fix linter warning on import of ConsumerRebalanceListener * Remove ConsumerTimeout * Return future from commit_offsets_async() Core / Protocol * Add protocol structs for {Describe,Create,Delete} Acls * Pre-compile pack/unpack function calls * Don't use kafka.common internally * Be explicit with tuples for %s formatting Documentation * Document connections_max_idle_ms * Fix sphinx url * Update remote urls: snappy, https, etc * Minor cleanup of testing doc * Various docstring / pep8 / code hygiene cleanups Test Infrastructure * Stop pinning pylint * (partial) Migrate from Unittest to pytest * Minor aesthetic cleanup of partitioner tests * Cleanup fixture imports * Fix typo in test file name * Remove unused ivy_root variable * Add test fixtures for kafka versions 1.0.2 -> 2.0.1 * Bump travis test for 1.x brokers to 1.1.1 Logging / Error Messages * raising logging level on messages signalling data loss * Stop using deprecated log.warn() * Fix typo in logging message Compatibility * Vendor enum34 * Bump vendored six to 1.11.0 * Vendor six consistently * Prevent pylint import errors on six.moves |
||
---|---|---|
.. | ||
DESCR | ||
distinfo | ||
Makefile | ||
PLIST |