cppkafka

cppkafka copied to clipboard

Hi i am trying to use this API but have been running into so many issues. I believe i am on the right track but i am getting the below...

krash11554

produer success but kafka shell consumer all "null"

1

` Configuration config = { { "metadata.broker.list", kafka_servers} }; Producer pp(config); MessageBuilder builder("***"); builder.partition(8); builder.payload("1999"); pp.produce(builder); pp.flush(); ` my code is like this. producer success. consumer got one message. but...

HuBlanker

How to use BufferedProducer to send binary data?

lutao518

Due to this issue: https://github.com/catchorg/Catch2/issues/2178 ``` In file included from /usr/include/signal.h:328, from /home/brennan/code/cppkafka/third_party/Catch2/single_include/catch.hpp:4811, from /home/brennan/code/cppkafka/tests/test_main.cpp:3: /home/brennan/code/cppkafka/third_party/Catch2/single_include/catch.hpp:7441:45: error: size of array ‘altStackMem’ is not an integral constant-expression 7441 | char FatalConditionHandler::altStackMem[SIGSTKSZ]...

umanwizard

Do not hardcode library path, this helps it install in right location independent of platforms, e.g. ppc64 uses lib64 and not lib Signed-off-by: Khem Raj

kraj

Consumer misbehavior with newer librdkafka versions

1

Hi, we was using this wrapper library over 1.3.x versions of librdkafka succesfully. Since we migrated to 1.7.0 our consumer do not receive events always or it stucks to not...

testillano

How to send serialized Avro data in a buffered producer?

2

I am trying to create an application that will serialize some data using Avro, and send it to a consumer client using Kafka. I am able to send a simple...

steinio

I want to be able to remove a topic using API, is there any such functionality defined in the library?

alphamarket

Modify the producer config trouble

1

Hello, I am playing with cppkafka. I would like to modify to part of the producer. 1 - reduce the time between each request currently is 100 ms 2 -...

wolfviking0

make examples failure

2

[root@VM-229-225-centos ~/news/ft_local/cppkafka/build]# make examples [ 63%] Built target cppkafka [ 68%] Built target consumers-information [ 73%] Built target producer [ 76%] Building CXX object examples/CMakeFiles/buffered-producer.dir/buffered_producer_example.cpp.o In file included from /root/news/ft_local/cppkafka/examples/buffered_producer_example.cpp:4:0:...

csflyer