cppkafka

cppkafka copied to clipboard

I want to define and create connection once. So I define these variables out of main ``` MessageBuilder *builder_appearance; Configuration *config_appearance; BufferedProducer *buffered_producer_appearance; ``` In a function I set parameters...

barzan-hayati

Added in compile required - _libssl-dev_

Oplkill

clang complains about this line: https://github.com/mfontanini/cppkafka/blame/9c5ea0e332486961e612deacc6e3f0c1874c688d/include/cppkafka/utils/buffered_producer.h#L664 C:\vcpkg\installed\x86-windows-utc-default\include\cppkafka/utils/buffered_producer.h(664,39): error G7095654A: no matching constructor for initialization of 'std::atomic_flag' [clang-diagnostic-error] mutable std::atomic_flag flag_{0}; ^~~ C:\Program Files\Microsoft Visual Studio\2022\Professional\VC\Tools\MSVC\14.38.33130\include\atomic:2829:20: note: candidate constructor (the implicit...

hotblack944

Since in this case rd_kafka_memberid() return NULL, and std::string cannot be constructed from NULL [1]. [1]: https://github.com/llvm/llvm-project/blob/fe51d8ae5772626ef8237c33e0911695cf4f07db/libcxx/include/string#L1051-L1055 Refs: https://github.com/ClickHouse/ClickHouse/issues/80674#issuecomment-2902812207

azat

Fix the destruction order of handle & destroy_flags

1

The MemorySanitizer detected a use-of-uninitialized-value issue caused by the destruction order in KafkaHandleBase. Specifically, the deleter of the Kafka handle accessed `destroy_flags_` after it had been destroyed because `destroy_flags_` was...

filimonov

These libraries are needed by librdkafka, not by cppkafka, hence there is no need to link them. Removing this fixes NixOS build of the library (NixOs does not provide zlib...

georgthegreat

georgthegreat

Hello, I'm trying to use the configuration: partition.assignment.strategy = cooperative-sticky However, after calling the subscribe method, I wonder if cppkafka is internally using rd_kafka_assign, which does not work correctly with...

jheffersonalves