thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 02:30:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Style

Browse Source
This commit is contained in:
Mikhail Filimonov 2020-05-19 19:02:37 +02:00
parent b50480cbde
commit 34198336ed
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/Kafka/KafkaBlockInputStream.cpp
View File

@ -135,7 +135,8 @@ Block KafkaBlockInputStream::readImpl()
auto new_rows = read_kafka_message();
// we can't store the offser after rebalance, when consumer is stalled, or if it's terminating
if (!buffer->storeLastReadMessageOffset()) {
if (!buffer->storeLastReadMessageOffset())
{
total_rows = 0;
break;
}