- Improvements in librdkafka archive download
- Add global statistics callback
- Use Time for timestamps, potentially breaking change if you rely on the previous behavior where it returns an integer with the number of milliseconds.
- Bump librdkafka to 0.11.5
- Implement TopicPartitionList in Ruby so we don't have to keep track of native objects.
- Support committing a topic partition list
- Add consumer assignment method
- Fix crash when not waiting for delivery handles
- Run specs on Ruby 2.5
- Bump librdkafka to 0.11.3
- Fix bug that prevent display of
RdkafkaError
message
add_topic
now supports using a partition count- Add way to make errors clearer with an extra message
- Show topics in subscribe error message
- Show partition and topic in query watermark offsets error message
- Bump librdkafka to 0.11.1
- Officially support ranges in
add_topic
for topic partition list. - Add consumer lag calculator
- Move both add topic methods to one
add_topic
inTopicPartitionList
- Add committed offsets to consumer
- Add query watermark offset to consumer
- Some refactoring and add inline documentation
- Initial working version including producing and consuming