创建ROUTINE LOAD Kafka任务报错Failed to get real offsets of kafka topic

Viewed 5

问题描述:在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

0 Answers