Skip to content

Commit f46eec9

Browse files
committed
Use EXCEPTIONS_DEPTH in KafkaConsumer2
1 parent 3bc9ab1 commit f46eec9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/Storages/Kafka/KafkaConsumer2.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,8 @@ bool KafkaConsumer2::TopicPartition::operator<(const TopicPartition & other) con
4343

4444
KafkaConsumer2::KafkaConsumer2(
4545
LoggerPtr log_, size_t max_batch_size, size_t poll_timeout_, const std::atomic<bool> & stopped_, const Names & topics_)
46-
: log(log_)
46+
: exceptions_buffer(EXCEPTIONS_DEPTH)
47+
, log(log_)
4748
, batch_size(max_batch_size)
4849
, poll_timeout(poll_timeout_)
4950
, stopped(stopped_)

0 commit comments

Comments
 (0)