cppkafka
cppkafka copied to clipboard
Modern C++ Apache Kafka client library (wrapper for librdkafka)
boost is very big, why not do not depend on it?
Hi, I had problems compiling your C++ wrapper because it could not find librdkafka. I found this new cmake extension that allowed me to find and compile the library: https://gist.github.com/matthew-d-jones/550ee6fa2f89610f88991513fa5d6cfc...
I have a question. I have saw the example.the consumer poll one message then will execute consumer.commit(msg). and I think Executive efficiency is very low. I want to know if...
Hello team! Thank you for your great work! The subjected release has a number or features like idempotent producer for instance that are highly desirable. I cannot tell though had...
When cppkafka does not send logs for a long time, the server will disconnect the kafka connection, causing the 500 error of the rest server when the kafka log is...
I built cppkafka (v0.3.0 release) with: ``` CPPKAFKA_BUILD_SHARED OFF CPPKAFKA_RDKAFKA_STATIC_LIB ON ``` cppkafka build was successful. Tried building `consumer_dispatcher_example.cpp`. Works on g++ 8.1.0 but when built (both the example and...
https://github.com/mfontanini/cppkafka/blob/2b66fd3a22a0b33458a27029df55cd8bca10cc7c/include/cppkafka/message_internal.h#L77 http://www.fly-server.ru/pvs-studio/cppkafka/
The most typical problem is to create consumer and then close it. It leads to this backtrace: ``` #0 cppkafka::Consumer::handle_rebalance (this=0x7ffefc002910, error=RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS, topic_partitions=...) at ../../contrib/cppkafka/src/consumer.cpp:303 #1 0x00007fffdf3dd75b in cppkafka::Consumer::rebalance_proxy (error=RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS,...
root@aebc7aa466c5:/postmanc/dockerbuild/cppkafka/build# cmake ../ -- The C compiler identification is GNU 4.8.4 -- The CXX compiler identification is GNU 4.8.4 -- Check for working C compiler: /usr/bin/cc -- Check for working...
It seems that librdkafka has support for the Kafka Topic Admin API (https://github.com/edenhill/librdkafka/issues/986), are there plans for implementing this in CppKafka? If this is not yet on the roadmap, would...