Releases: tarantool/kafka
Releases · tarantool/kafka
Release 1.5.0
- disable zstd linking in static build
- push errors from rd_kafka_consumer_poll to error queue
- fix possible consumer hang in case of errors
- support kafka headers for consumer and producer
- fix parallel build of kafka module
Release 1.4.2
- New function "metadata"
consumer:metadata({timeout_ms = })
producer:metadata({timeout_ms = }, topic = <topic(string)>) - New function "list_groups"
consumer:list_groups({group = <group(string)>, timeout_ms = ...})
producer:list_groups({group = <group(string)>, timeout_ms = ...})
Release 1.4.1
- Fix crash on consumer close
- Fix possible memory leaks in case of errors
Release 1.4.0
- Update librdkafka to v1.8.2
- Fix several issues that could lead to crashes
- Implement stats callback
- Introduce dump_conf function to get current producer/consumer configuration
Fix issue with `free` invalid data
Merge pull request #36 from tarantool/filonenko-mikhail-patch-1 Update consumer_msg.c
Resolve issues with close and __gc methods
Fixed issues:
- consumer and producer yields in lua __gc meta methods which leads to crash for whole tarantool (?) - fixed by removing lua __gc meta methods and moving it's logic into separate destroy C functions which will be called from lua close methods of Consumer / Producer
- consumer:close sometimes hangs forever - fixed byfollowing changes:
- now we instantly destroying librdkafka messages on consume in poll thread which prevents rd_kafka_close and rd_kafka_destroy C functions hangs cause of busy resources
- now lua Consumer stops polling fibers only after librdkafka consumer was closed which prevents non handeled callbacks from closing operation
- producer sometimes hangs forever - updated librdkafka to 1.5.2
First production ready release
Changes:
- static build now working as expected
- added support for rebalance callback to consumer
- moved polling calls to background thread that leads to huge performance improve
Bundle with librdkafka build option and package rename
v0.5.0 added rockspec for 0.5.0 version
C sources refactoring and few new features
-
added unsubscribe method to consumer;
-
added log and error callbacks to consumer and to producer
-
added default options for topics to consumer and producer
Reworked library from ffi to pure c wrapper.
Breaking changes in public functions api.
Huge performance and memory consumption improvements.
Producer now able to produce messages with non nil keys.