【详述】Routine 任务连接kafka失败
【StarRocks版本】3.4.0
【联系方式】vfight@hotmail.com
docker安装starrocks和kafka
创建 Routine任务导入数据，实测在starrocks的docker内可以连接到kafka的docker，IP端口配置都没问题，但是运行任务报错，什么情况
CREATE ROUTINE LOAD task_sync_status ON sync_status
COLUMNS(chain, blocknumber, blocktime, sol_price)
PROPERTIES
(
“format” = “json”,
“jsonpaths” = “[”$.chain","$.blocknumber","$.blocktime","$.sol_price"]"
)
FROM KAFKA
(
“kafka_broker_list” = “172.17.0.3:9092”,
“kafka_topic” = “rsquantex_sync_status”,
“property.kafka_default_offsets” = “OFFSET_BEGINNING”
);
ErrorReason{errCode = 2, msg=‘Failed to send get kafka partition info request to BE TNetworkAddress(hostname:127.0.0.1, port:8060), err: Ocurrs time out with specfied time 12 SECONDS’}
我特意测试配错kafka的IP，会报另一个错：
ErrorReason{errCode = 4, msg=‘Job failed to fetch all current partition with error [failed to get kafka topic: rsquantex_sync_status meta, err: Local: Broker transport failure, event: [thrd:127.0.0.1:9092/bootstrap]: 127.0.0.1:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT), BE: TNetworkAddress(hostname:127.0.0.1, port:8060)]’}