diff --git a/include/cppkafka/utils/roundrobin_poll_strategy.h b/include/cppkafka/utils/roundrobin_poll_strategy.h index 6ad89714..3d884f47 100644 --- a/include/cppkafka/utils/roundrobin_poll_strategy.h +++ b/include/cppkafka/utils/roundrobin_poll_strategy.h @@ -180,8 +180,8 @@ void RoundRobinPollStrategy::consume_batch(Queue& queue, } // concatenate both lists messages.insert(messages.end(), - make_move_iterator(queue_messages.begin()), - make_move_iterator(queue_messages.end())); + std::make_move_iterator(queue_messages.begin()), + std::make_move_iterator(queue_messages.end())); // reduce total batch count count -= queue_messages.size(); }