scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-02 19:47:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #261 from hanickadot/master

Browse Source 
Ability to block producer in case the underlying queue is full.
This commit is contained in:
Matias Fontanini
2020-08-15 18:03:15 -07:00
committed by GitHub
parent b06e64ef5b a032f9a1e8
commit e5dfd5085c
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
include/cppkafka/producer.h
View File

@@ -86,9 +86,10 @@ public:
* The policy to use for the payload. The default policy is COPY_PAYLOAD * The policy to use for the payload. The default policy is COPY_PAYLOAD
*/ */
enum class PayloadPolicy { enum class PayloadPolicy {
PASSTHROUGH_PAYLOAD = 0, ///< Rdkafka will not copy nor free the payload. PASSTHROUGH_PAYLOAD = 0, ///< Rdkafka will not copy nor free the payload.
COPY_PAYLOAD = RD_KAFKA_MSG_F_COPY, ///< Means RD_KAFKA_MSG_F_COPY COPY_PAYLOAD = RD_KAFKA_MSG_F_COPY, ///< Means RD_KAFKA_MSG_F_COPY
FREE_PAYLOAD = RD_KAFKA_MSG_F_FREE ///< Means RD_KAFKA_MSG_F_FREE FREE_PAYLOAD = RD_KAFKA_MSG_F_FREE, ///< Means RD_KAFKA_MSG_F_FREE
BLOCK_ON_FULL_QUEUE = RD_KAFKA_MSG_F_BLOCK ///< Producer will block if the underlying queue is full
}; };
/** /**