scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-03 20:18:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Persist message's user data when retrying on buffered producer

Browse Source
This commit is contained in:
Matias Fontanini
2017-09-17 15:46:23 -07:00
parent 4c9aa6fcd4
commit 17da880854
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/cppkafka/message.h
View File

@@ -134,7 +134,7 @@ public:
* This should only be used on messages produced by a Producer that were set a private data
* attribute
*/
void* get_private_data() const {
void* get_user_data() const {
return handle_->_private;
}

3
include/cppkafka/utils/buffered_producer.h
View File

@@ -297,7 +297,8 @@ void BufferedProducer<BufferType>::on_delivery_report(const Message& message) {
const auto& payload = message.get_payload();
builder.partition(message.get_partition())
.key(Buffer(key.get_data(), key.get_size()))
.payload(Buffer(payload.get_data(), payload.get_size()));
.payload(Buffer(payload.get_data(), payload.get_size()))
.user_data(message.get_user_data());
if (message.get_timestamp()) {
builder.timestamp(message.get_timestamp()->get_timestamp());
}