kafka
kafka copied to clipboard
Full featured high performance kafka library for Tarantool based on librdkafka.
Before this patch we didn't free some resources in case of error in Consumer.create or Producer.create functions. This patch fixes it. Closes https://github.com/tarantool/kafka/issues/108
https://github.com/tarantool/kafka/blob/825579a7dd18af8372158499b58d85ce2207bf15/kafka/consumer.c#L707-L711 This part seems to cause a memory leak. Because nobody frees `rd_consumer` handle.
**Environment:** ``` ProductName: macOS ProductVersion: 11.7 BuildVersion: 20G817 Tarantool 2.10.4-0-g816000e Target: Darwin-x86_64-Release Build options: cmake . -DCMAKE_INSTALL_PREFIX=/usr/local/Cellar/tarantool/2.10.4 -DENABLE_BACKTRACE=ON Compiler: /usr/bin/clang /usr/bin/clang++ C_FLAGS: -fexceptions -funwind-tables -fno-common -fopenmp -msse2 -Wformat -Wformat-security -Werror=format-security...
Probably module should offer some easy way to get metrics from consumer/producer object. See https://github.com/tarantool/kafka/commit/f3fa471f1baebe510dabed2473d2d3defc8b33ac