问题描述:在Doris中使用SQL创建ROUTINE LOAD Kafka导入任务时,执行SQL后等很久,然后报错Failed to get real offsets of kafka topic。
Doris版本:doris-2.1.10
创建ROUTINE LOAD语句:
CREATE ROUTINE LOAD testdb.at_pmmodulepassworkcenter_dsg ON at_pmmodulepassworkcenter_dsg
PROPERTIES
(
"desired_concurrent_number"="3",
"format" = "json",
"strict_mode" = "false"
)
FROM KAFKA
(
"kafka_broker_list" = "**.**.**:**",
"kafka_topic" = "orc_mes_module_hs_logs",
"kafka_partitions" = "18",
"property.group.id" = "module_doris_zx",
"property.kafka_default_offsets" = "OFFSET_BEGINNING",
"property.security.protocol" = "SASL_PLAINTEXT",
"property.sasl.kerberos.service.name" = "kafka",
"property.sasl.kerberos.keytab" = "/data/doris/kafka/kerberos/krb5.keytab",
"property.sasl.kerberos.keytab"="/data/doris/kafka/kerberos/***.keytab",
"property.sasl.kerberos.principal" = "***@***.***"
);
报错:
[2025-10-22 14:54:36] [HY000][1105] errCode = 2, detailMessage = Failed to get real offsets of kafka topic: orc_mes_module_hs_logs. error: errCode = 2, detailMessage = Failed to get info