Skip to content

Releases: tarantool/kafka

Release 1.5.0

04 Mar 17:14
Compare
Choose a tag to compare
  • 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

01 Feb 19:04
Compare
Choose a tag to compare
  • 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

22 Dec 08:34
Compare
Choose a tag to compare
  • Fix crash on consumer close
  • Fix possible memory leaks in case of errors

Release 1.4.0

15 Dec 09:15
Compare
Choose a tag to compare
  • 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

21 Jan 13:09
cf5d732
Compare
Choose a tag to compare
Merge pull request #36 from tarantool/filonenko-mikhail-patch-1

Update consumer_msg.c

Resolve issues with close and __gc methods

10 Dec 09:03
44c01aa
Compare
Choose a tag to compare

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

06 Jun 20:33
ce3dac3
Compare
Choose a tag to compare

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

24 May 08:45
Compare
Choose a tag to compare
v0.5.0

added rockspec for 0.5.0 version

C sources refactoring and few new features

06 Feb 13:09
Compare
Choose a tag to compare
  • 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.

01 Feb 16:38
Compare
Choose a tag to compare

Breaking changes in public functions api.
Huge performance and memory consumption improvements.
Producer now able to produce messages with non nil keys.