cppkafka
cppkafka copied to clipboard
mfontanini
Modern C++ Apache Kafka client library (wrapper for librdkafka)
how to send flatbuffer data to kafka through cpp kafka?
g++ example.cc -lrdkafka -lpthread -lz -lstdc++ -lcppkafka throws below error example.cc: undefined reference to `cppkafka::ConfigurationOption::ConfigurationOption(std::__cxx11::basic_string const&, char const*)' example.cc: undefined reference to `cppkafka::Buffer::Buffer(std::__cxx11::basic_string const&)' but when compile with below option,...
Hi @mfontanini, is there any reason why the offset is not part of the [comparison](https://github.com/mfontanini/cppkafka/blob/master/src/topic_partition.cpp#L88)?
Hi, I'd like to now if is possible to subscribe a new topic while the consumer is running. I've based my code on the example of the consumer using the...
I wrote C++ consumer for kafka messages using cppkafka library. I have problem while running program. Sometimes there is problem with Segmentation fault (core dumped) before topic assigned, but sometimes...
Hello, I tried the suggested options in #206 and I still run into the issue. This is the CMake command, which I used: `cmake .. -DCPPKAFKA_RDKAFKA_STATIC_LIB=ON -DCPPKAFKA_BUILD_SHARED=OFF -DBOOST_INCLUDEDIR="path to project\packages\boost.1.70.0.0\lib\native\include"...
Now I use buffered producer and add_message to write data to kafka. But before flushing, I want to measure something on each data from producer's buffer. So, how can I...
I use the api just like using poll. but I always get zero size vector?
I have installed all dependencies required from librdkafka to boost. Not familiar with cpp. Please help.
The leak is detected via address sanitizer here: https://github.com/mfontanini/cppkafka/blob/master/src/consumer.cpp#L66 The `rd_kafka_new()` internally doesn't free `app_conf` on failure. So the dupped configuration handler gets lost.
Metadata
Owner
Metadata
Modern C++ Apache Kafka client library (wrapper for librdkafka)