mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-22 01:30:51 +00:00
Fix trivial bug in code
This commit is contained in:
parent
bbf9fd3c17
commit
a9b02e8184
@ -416,7 +416,7 @@ size_t ReadBufferFromKafkaConsumer::filterMessageErrors()
|
||||
return false;
|
||||
});
|
||||
|
||||
size_t skipped = std::distance(messages.end(), new_end);
|
||||
size_t skipped = std::distance(new_end, messages.end());
|
||||
if (skipped)
|
||||
{
|
||||
LOG_ERROR(log, "There were {} messages with an error", skipped);
|
||||
|
Loading…
Reference in New Issue
Block a user