Bot releases are visible (Hide)
Published by tvoinarovskyi about 7 years ago
Starting from 0.3.0 we discourage imports from kafka
namespace. Starting from 0.4.0
aiokafka will stop supporting objects imported from kafka
namespace. Please import from aiokafka
namespaces instead.
aiokafka
namespace. You will nokafka
namespace.on_partitions_assigned
and on_partitions_revoked
callbacks. (PR #190offsets_for_times
, beginning_offsets
, end_offsets
seek_to_end
, seek_to_beginning
API's. (issue #154)Published by tvoinarovskyi about 7 years ago
Published by tvoinarovskyi over 7 years ago
getmany
will no longer return 0 results before timeout. (issue #117)Big thanks to @Artimi for pointing out several of those issues.
Published by tvoinarovskyi over 7 years ago
consumer.stop()
call. Any new get*
calls will result in ConsumerStoppedError (PR #81)exclude_internal_topics
option for Consumer (PR #111)group_id
(part of PR #111)subscribe
and JoinGroup race condition (issue #88). Coordinator will now notice subscription changes during rebalance and will join group again. (PR #106)connections_max_idle_ms
config (PR #113)Published by tvoinarovskyi almost 8 years ago
next_record
recursion (PR #94 by fabregas)max_poll_records
option for Consumer (PR #72 by Drizzt1991)Published by tvoinarovskyi almost 8 years ago
timestamp
to be associated with messages.Big thanks to @fabregas for the hard work on this release (PR #60)
Published by tvoinarovskyi about 8 years ago
Published by tvoinarovskyi over 8 years ago
Fix packaging issues. Removed unneeded files from package.
Published by tvoinarovskyi over 8 years ago
Added full support for Kafka 9.0. Older Kafka versions are not tested.