thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-28 18:42:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix style

Browse Source
This commit is contained in:
János Benjamin Antal 2024-06-18 14:30:23 +00:00
parent f2e4ec28cb
commit 65fc6fe8a3
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -252,7 +252,8 @@ void KafkaConsumer2::updateOffsets(const TopicPartitions & topic_partitions)
topic_partitions.begin(),
topic_partitions.end(),
std::back_inserter(original_topic_partitions),
[](const TopicPartition & tp) {
[](const TopicPartition & tp)
{
return cppkafka::TopicPartition{tp.topic, tp.partition_id, tp.offset};
});
initializeQueues(original_topic_partitions);

1
src/Storages/Kafka/StorageKafka2.cpp
View File

@ -92,7 +92,6 @@ extern const int NOT_IMPLEMENTED;
extern const int LOGICAL_ERROR;
extern const int REPLICA_ALREADY_EXISTS;
extern const int TABLE_IS_DROPPED;
extern const int TABLE_WAS_NOT_DROPPED;
extern const int NO_ZOOKEEPER;
extern const int REPLICA_IS_ALREADY_ACTIVE;
}