We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7729826 commit 6f28322Copy full SHA for 6f28322
kafka/src/kafka/impl/producer_impl.cpp
@@ -324,7 +324,7 @@ void ProducerImpl::WaitUntilDeliveryReported(engine::Future<DeliveryResult>& del
324
continue;
325
}
326
327
- auto waked_up_by = engine::WaitAny(waiter.event, delivery_result);
+ auto waked_up_by = engine::MakeWaitAny(waiter.event, delivery_result).Wait();
328
LOG(debug_info_log_level_) << fmt::format(
329
"Wake up reason: {}",
330
waked_up_by.has_value() ? (waked_up_by == 0 ? "EventCallback" : "DeliveryResult") : "Cancel"
0 commit comments