# 0.13.1 * Add offsets_for_times method on consumer (timflapper) # 0.13.0 * Support cooperative sticky partition assignment in the rebalance callback (methodmissing) * Support both string and symbol header keys (ColinDKelley) * Handle tombstone messages properly (kgalieva) * Add topic name to delivery report (maeve) * Allow string partitioner config (mollyegibson) * Fix documented type for DeliveryReport#error (jimmydo) * Bump librdkafka to 2.0.2 (lmaia) * Use finalizers to cleanly exit producer and admin (thijsc) * Lock access to the native kafka client (thijsc) * Fix potential race condition in multi-threaded producer (mensfeld) * Fix leaking FFI resources in specs (mensfeld) * Improve specs stability (mensfeld) * Make metadata request timeout configurable (mensfeld) * call_on_partitions_assigned and call_on_partitions_revoked only get a tpl passed in (thijsc) * Support `#assignment_lost?` on a consumer to check for involuntary assignment revocation (mensfeld) * Expose `#name` on the consumer and producer (mensfeld) * Introduce producer partitions count metadata cache (mensfeld) * Retry metadta fetches on certain errors with a backoff (mensfeld) * Do not lock access to underlying native kafka client and rely on Karafka granular locking (mensfeld) # 0.12.3 - Include backtrace in non-raised binded errors. - Include topic name in the delivery reports # 0.12.2 * Increase the metadata default timeout from 250ms to 2 seconds. This should allow for working with remote clusters. # 0.12.1 * Bumps librdkafka to 2.0.2 (lmaia) * Add support for adding more partitions via Admin API # 0.12.0 * Bumps librdkafka to 1.9.0 * Fix crash on empty partition key (mensfeld) * Pass the delivery handle to the callback (gvisokinskas) # 0.11.0 * Upgrade librdkafka to 1.8.2 * Bump supported minimum Ruby version to 2.6 * Better homebrew path detection # 0.10.0 * Upgrade librdkafka to 1.5.0 * Add error callback config # 0.9.0 * Fixes for Ruby 3.0 * Allow any callable object for callbacks (gremerritt) * Reduce memory allocations in Rdkafka::Producer#produce (jturkel) * Use queue as log callback to avoid unsafe calls from trap context (breunigs) * Allow passing in topic configuration on create_topic (dezka) * Add each_batch method to consumer (mgrosso) # 0.8.1 * Fix topic_flag behaviour and add tests for Metadata (geoff2k) * Add topic admin interface (geoff2k) * Raise an exception if @native_kafka is nil (geoff2k) * Option to use zstd compression (jasonmartens) # 0.8.0 * Upgrade librdkafka to 1.4.0 * Integrate librdkafka metadata API and add partition_key (by Adithya-copart) * Ruby 2.7 compatibility fix (by Geoff TheĢ)A * Add error to delivery report (by Alex Stanovsky) * Don't override CPPFLAGS and LDFLAGS if already set on Mac (by Hiroshi Hatake) * Allow use of Rake 13.x and up (by Tomasz Pajor) # 0.7.0 * Bump librdkafka to 1.2.0 (by rob-as) * Allow customizing the wait time for delivery report availability (by mensfeld) # 0.6.0 * Bump librdkafka to 1.1.0 (by Chris Gaffney) * Implement seek (by breunigs) # 0.5.0 * Bump librdkafka to 1.0.0 (by breunigs) * Add cluster and member information (by dmexe) * Support message headers for consumer & producer (by dmexe) * Add consumer rebalance listener (by dmexe) * Implement pause/resume partitions (by dmexe) # 0.4.2 * Delivery callback for producer * Document list param of commit method * Use default Homebrew openssl location if present * Consumer lag handles empty topics * End iteration in consumer when it is closed * Add support for storing message offsets * Add missing runtime dependency to rake # 0.4.1 * Bump librdkafka to 0.11.6 # 0.4.0 * 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 # 0.3.5 * Fix crash when not waiting for delivery handles * Run specs on Ruby 2.5 # 0.3.4 * Bump librdkafka to 0.11.3 # 0.3.3 * Fix bug that prevent display of `RdkafkaError` message # 0.3.2 * `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 # 0.3.1 * Bump librdkafka to 0.11.1 * Officially support ranges in `add_topic` for topic partition list. * Add consumer lag calculator # 0.3.0 * Move both add topic methods to one `add_topic` in `TopicPartitionList` * Add committed offsets to consumer * Add query watermark offset to consumer # 0.2.0 * Some refactoring and add inline documentation # 0.1.x * Initial working version including producing and consuming