[ https://issues.apache.org/jira/browse/MINIFICPP-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Marton Szasz closed MINIFICPP-1257. ----------------------------------- > PublishKafka should not leak messages on failed produce > ------------------------------------------------------- > > Key: MINIFICPP-1257 > URL: https://issues.apache.org/jira/browse/MINIFICPP-1257 > Project: Apache NiFi MiNiFi C++ > Issue Type: Bug > Reporter: Marton Szasz > Assignee: Marton Szasz > Priority: Blocker > Fix For: 0.9.0 > > Time Spent: 50m > Remaining Estimate: 0h > > On failure `rd_kafka_producev` doesn't call > PublishKafka::messageDeliveryCallback, which takes ownership of the messages, > leaking the whole batch if any of the deliveries fail. > > -- This message was sent by Atlassian Jira (v8.3.4#803005)