libkafka-asio
libkafka-asio copied to clipboard
danieljoos
C++ Kafka Client Library using Boost Asio
Hi - We've been testing libkafka-asio for a while and it has been great. However, we run into this error once in a while and haven't been able to figure...
when the socket connect failed, have no api to help to reconnect after an duration times. if we connect after handlequest failed, this will generate many socket time_wait.
I'm using libkafka-asio in my project. When using FetchRequest::FetchTopic `void FetchTopic(const String& topic_name, Int32 partition, Int64 fetch_offset, Int32 max_bytes)` I can only fetch messages whose size is less than `max_bytes`,...
Can you add this library into vcpkg (https://github.com/Microsoft/vcpkg) ? Thanks.
Hi, guys: You guys really did a great work, really appreciate your time and talent of contributing to the open source world. I recently play with the client and found...
It is possible to set the `Key` for a message on the message and then pass it to `AddMessage` but there is no way to set it with `AddValue`. This...
