1.0.2-beta
Pre-release
Pre-release
- Updated dev dependency version constraints to allow major version updates
- Changed _consumer_handler function signature, adding commit_each_message flag
- Moved get_consumer and get_producer into Topic as private methods
- Topic.next uses own Consumer instance that's closed down correctly
- Fixed slicing bug involving start and end slice parameters
- Made underlying Consumer and Producer instances available under Topic.consumer and Topic.producer