From a1101e5278b24781e97fded4251ffe5a04e7b9c5 Mon Sep 17 00:00:00 2001
From: Alexey Milovidov <milovidov@yandex-team.ru>
Date: Wed, 28 Aug 2019 16:21:19 +0300
Subject: [PATCH] Fixed build

---
 dbms/src/Databases/DatabasesCommon.h            | 1 +
 dbms/src/Storages/Kafka/KafkaBlockInputStream.h | 2 ++
 dbms/src/Storages/Kafka/StorageKafka.h          | 2 ++
 3 files changed, 5 insertions(+)

diff --git a/dbms/src/Databases/DatabasesCommon.h b/dbms/src/Databases/DatabasesCommon.h
index 00190d89b1e..734708e4c95 100644
--- a/dbms/src/Databases/DatabasesCommon.h
+++ b/dbms/src/Databases/DatabasesCommon.h
@@ -4,6 +4,7 @@
 #include <Parsers/IAST.h>
 #include <Storages/IStorage_fwd.h>
 #include <Databases/IDatabase.h>
+#include <mutex>
 
 
 /// General functionality for several different database engines.
diff --git a/dbms/src/Storages/Kafka/KafkaBlockInputStream.h b/dbms/src/Storages/Kafka/KafkaBlockInputStream.h
index fef7f8d0469..011ed5fe046 100644
--- a/dbms/src/Storages/Kafka/KafkaBlockInputStream.h
+++ b/dbms/src/Storages/Kafka/KafkaBlockInputStream.h
@@ -4,6 +4,8 @@
 #include <Interpreters/Context.h>
 
 #include <Storages/Kafka/StorageKafka.h>
+#include <Storages/Kafka/ReadBufferFromKafkaConsumer.h>
+
 
 namespace DB
 {
diff --git a/dbms/src/Storages/Kafka/StorageKafka.h b/dbms/src/Storages/Kafka/StorageKafka.h
index 2353d1abe44..51a06a890db 100644
--- a/dbms/src/Storages/Kafka/StorageKafka.h
+++ b/dbms/src/Storages/Kafka/StorageKafka.h
@@ -2,6 +2,8 @@
 
 #include <Core/BackgroundSchedulePool.h>
 #include <Storages/IStorage.h>
+#include <Storages/Kafka/ReadBufferFromKafkaConsumer.h>
+#include <Storages/Kafka/WriteBufferToKafkaProducer.h>
 
 #include <Poco/Semaphore.h>
 #include <ext/shared_ptr_helper.h>