全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Doris中的Routine Load的工作原理是什么？

提问者：帅平问题分类：面试刷题

Doris面试题 Doris

发布于：2周前 (05-21) IP属地：

1 个回答

逾

Routine Load是一种持续消费消息队列（如Kafka）并自动导入数据的异步机制，常用于从kafka中导入数据，使用示例如下：

CREATE ROUTINE LOAD db.job_name ON table_name
PROPERTIES (
    "desired_concurrent_number"="3",  -- 并发任务数
    "max_batch_interval"="20"         -- 任务间隔（秒）
)
FROM KAFKA (
    "kafka_broker_list" = "broker1:9092,broker2:9092",
    "kafka_topic" = "user_behavior",
    "property.group.id" = "doris_consumer_group"
);

发布于：2周前 (05-21) IP属地：

我来回答