为了更快的定位您的问题，请提供以下信息，谢谢
【详述】无法使用 kafka Routine Load 数据导入
【背景】按照 https://docs.starrocks.io/zh/docs/loading/RoutineLoad/ 文档进行第一个实例操作。发现无法导入数据。出现报错：
ErrorReason{errCode = 2, msg=‘failed to send proxy request to TNetworkAddress(hostname:kube-starrocks-test-be-0.kube-starrocks-test-be-search.starrocks-test.svc.cluster.local, port:8060) err failed to send proxy request to TNetworkAddress(hostname:kube-starrocks-test-be-0.kube-starrocks-test-be-search.starrocks-test.svc.cluster.local, port:8060) err [failed to query watermark offset, err: Local: Bad message format]’}
【排查】发现 Kafka 数据正常有数据，[root@hcss-ecs-0449 kafka_2.13-3.6.0]# bin/kafka-console-consumer.sh --topic ordertest1 --from-beginning --bootstrap-server localhost:9092
2020050802,2020-05-08,Johann Georg Faust,Deutschland,male,895
建表，创建如下：
CREATE TABLE example_tbl1 (
order_id bigint NOT NULL COMMENT “订单编号”,
pay_dt date NOT NULL COMMENT “支付日期”,
customer_name varchar(26) NULL COMMENT “顾客姓名”,
nationality varchar(26) NULL COMMENT “国籍”,
pricedouble NULL COMMENT “支付金额”
)
ENGINE=OLAP
DUPLICATE KEY (order_id,pay_dt)
DISTRIBUTED BY HASH(order_id)
PROPERTIES (
“replication_num” = “1”
);
CREATE ROUTINE LOAD example_tbl1_ordertest1 ON example_tbl1
COLUMNS TERMINATED BY “,”,
COLUMNS (order_id, pay_dt, customer_name, nationality, temp_gender, price)
PROPERTIES
(
“desired_concurrent_number” = “1”
)
FROM KAFKA
(
“kafka_broker_list” = “localhost:9092”,
“kafka_topic” = “ordertest1”,
“kafka_partitions” = “0”,
“property.kafka_default_offsets” = “OFFSET_BEGINNING”
);
starkrock 使用的是使用 helm 搭建的 k8s 集群 3.2 版本。