We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fd3fb70 commit 6bb0da9Copy full SHA for 6bb0da9
src/Storages/ExternalStream/Kafka/KafkaSource.cpp
@@ -49,6 +49,8 @@ KafkaSource::KafkaSource(
49
, virtual_col_types(header.columns(), nullptr)
50
, ckpt_data(consume_ctx)
51
{
52
+ is_streaming = true;
53
+
54
calculateColumnPositions();
55
initConsumer(kafka);
56
initFormatExecutor(kafka);
0 commit comments