Skip to content

Commit 00370c9

Browse files
committed
Fixed spacing issues
1 parent 97229eb commit 00370c9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

include/cppkafka/utils/buffered_producer.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -682,7 +682,7 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
682682
std::swap(messages_, flush_queue);
683683
}
684684
auto remaining = timeout;
685-
auto start_time = std::chrono::high_resolution_clock::now();
685+
auto start_time = std::chrono::high_resolution_clock::now();
686686
do {
687687
if (!hi_pri_flush_queue.empty()) {
688688
sync_produce(hi_pri_flush_queue.front());
@@ -824,7 +824,7 @@ void BufferedProducer<BufferType, Allocator>::do_add_message(BuilderType&& build
824824
else {
825825
async_flush();
826826
}
827-
}
827+
}
828828
}
829829

830830
template <typename BufferType, typename Allocator>

0 commit comments

Comments
 (0)