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