SingleStore:注册登录无法获得管道的源元数据。创建使用者失败: ssl.ca.location失败:没有进一步的错误信息

Question

下面是我正在使用的命令，但是当我创建kafka管道命令时，我得到以下错误: ERROR 1933 ER_EXTRACTOR_EXTRACTOR_GET_LATEST_OFFSETS:无法获得管道的源元数据。创建使用者失败: ssl.ca.location失败:没有其他可用的错误信息

使用的命令：

CREATE PIPELINE ticketmaster_pipeline AS

LOAD DATA KAFKA ‘b-3.etainmentnonprod.z2xjta.c25.kafka.us-east-1.amazonaws.com:9094,b-1.etainmentnonprod.z2xjta.c25.kafka.us-east-1.amazonaws.com:9094,b-2.etainmentnonprod.z2xjta.c25.kafka.us-east-1.amazonaws.com:9094/ticketmaster’

CONFIG '{“sasl.username”: “AWS_ACCESS_KEY”,

     "sasl.mechanism": "PLAIN",

     "security.protocol": "SASL_SSL",

     "ssl.ca.location": "/etc/pki/ca-trust/extracted/java/cacerts"}'
CREDENTIALS ‘{“sasl.password”: “AWS_PSWD/Z”}’

INTO TABLE ticketmaster_kafka

FORMAT JSON (event_url ← event_url,event_id ← event_id,timestamp ← timestamp,event_name ← event_name,venue ← venue,event_datetime ← event_datetime,city ← city,state ← state,section ← section,row ← row,qty ← qty,seat_ids ← seat_ids,seat_numbers ← seat_numbers,inventory_type ← inventory_type,price ← price);

我的kafka设置在AWS MSK insatnce上，我在这个主题中有数据

Answer 1

这是一个身份验证问题，我们可以通过删除配置‘{“security.protocol：”ssl“}之外的所有内容来解决它。

请试试这个：

创建管道ticketmaster_pipeline作为加载数据卡夫卡ticketmaster_pipeline配置‘{“security.protocol："SSL"}’

表ticketmaster_kafka格式JSON ( event_url←event_url、event_id←event_id、时间戳inventory_type时间戳、event_name inventory_type event_name、场馆管理场所、event_datetime event_datetime、城市城市、州、区段、排排、qty event_url、seat_ids seat_ids、seat_numbers、inventory_type inventory_type、价格价格)；