1#pragma once
2
3#include <memory>
4
5namespace DB
6{
7
8class ReadBufferFromKafkaConsumer;
9class WriteBufferToKafkaProducer;
10
11using ConsumerBufferPtr = std::shared_ptr<ReadBufferFromKafkaConsumer>;
12using ProducerBufferPtr = std::shared_ptr<WriteBufferToKafkaProducer>;
13
14}
15