【详述】使用routine load 的时候 通过sasl认证kafka失败
【导入/导出方式】
【背景】做过哪些操作？
【业务影响】
【StarRocks版本】例如：2.3.0
【集群规模】1fe+1be（fe与be混部）
【机器信息】8C/8G/万兆
【附件】
根据starrocks 文档中描述：
2.使用 SASL 连接 Kafka 时，需要指定以下参数： “property.security.protocol”=“SASL_PLAINTEXT”, “property.sasl.mechanism”=“PLAIN”, “property.sasl.username”=“admin”, “property.sasl.password”="admin"其中： “property.security.protocol” 指定协议为 SASL_PLAINTEXT。 “property.sasl.mechanism” 指定 SASL 的 认证方式为 PLAIN。 “property.sasl.username” 指定 SASL 的用户名。 “property.sasl.password” 指定 SASL 的密码。
下面是我的导入任务注册语句。
CREATE ROUTINE LOAD kafkaLoadTest.customer_test0906 ON customer
COLUMNS(c_custkey, c_name, c_address, c_city, c_nation, c_region, c_phone, c_mktsegment)
PROPERTIES
(
“desired_concurrent_number” = “1”,
“max_batch_interval” = “20”,
“strict_mode” = “false”,
“format” = “json”
)
FROM KAFKA
(
“kafka_broker_list” = “”,
“kafka_topic” = “my_topic”,
“property.security.protocol”=“SASL_PLAINTEXT”,
“property.sasl.mechanism”=“PLAIN”,
“property.sasl.username”="",
“property.sasl.password”=""
);
这个是be.INFO中截取的异常日志
I0906 10:05:03.082118 36749 data_consumer.h:91] kafka log-3-FAIL, event: [thrd:sasl_plaintext://:9092/bootstrap]: sasl_plaintext://:9092/bootstrap: SASL PLAIN mechanism handshake failed: Broker: Request not valid in current SASL state: broker’s supported mechanisms: GSSAPI (after 0ms in state AUTH_HANDSHAKE, 1 identical error(s) suppressed)
这个是show routine load中显示的信息
ErrorReason{errCode = 4, msg=‘Job failed to fetch all current partition with error [failed to send proxy request to TNetworkAddress(hostname:, port:8060) err failed to send proxy request to TNetworkAddress(hostname:, port:8060) err [failed to get partition meta: Local: Broker transport failure]]’
想问一下大佬们，这个问题该怎么处理。