Routine load failed when followed by official guide

[CzyerChen]

Version

doris : 3.0.5
kafka : 3.6.1 single node

Routine load task

CREATE ROUTINE LOAD testdb.example_routine_load_csv ON test_streamload
COLUMNS TERMINATED BY ",",
COLUMNS(user_id, name, age)
FROM KAFKA(
    "kafka_broker_list" = "127.0.0.1:9092",
    "kafka_topic" = "test-routine-load-csv",
    "property.kafka_default_offsets" = "OFFSET_BEGINNING"
);

Kafka

1. create topic

$ bin/kafka-topics.sh --create --topic test-routine-load-csv --partitions 3 --replication-factor 1 --bootstrap-server 127.0.0.1:9092
Created topic test-routine-load-csv.

2. produce data

$ bin/kafka-console-producer.sh   --bootstrap-server 127.0.0.1:9092   --topic test-routine-load-csv
>1,Emily,25
>2,Benjamin,35

Result

('1748932956940', 'example_routine_load_csv', '2025-06-05 15:15:19', '2025-06-05 15:17:14', NULL, 'testdb', 'test_streamload', 'false', 'PAUSED', 'KAFKA', '0', '{"max_batch_rows":"20000000","timezone":"Asia/Shanghai","send_batch_parallelism":"1","load_to_single_tablet":"false","column_separator":"','","line_delimiter":"\n","current_concurrent_number":"0","delete":"","partial_columns":"false","merge_type":"APPEND","exec_mem_limit":"2147483648","strict_mode":"false","jsonpaths":"","max_batch_interval":"60","max_batch_size":"1073741824","fuzzy_parse":"false","escape":"0","enclose":"0","partitions":"","columnToColumnExpr":"user_id,name,age","whereExpr":"","desired_concurrent_number":"256","precedingFilter":"","format":"csv","max_error_number":"0","max_filter_ratio":"1.0","json_root":"","strip_outer_array":"false","num_as_string":"false"}', '{"topic":"test-routine-load-csv","currentKafkaPartitions":"","brokerList":"127.0.0.1:9092"}', '{"kafka_default_offsets":"OFFSET_BEGINNING","group.id":"example_routine_load_csv_714c75a7-65e1-485c-a0c1-667fb8a85d23"}', '{"receivedBytes":0,"runningTxns":[],"errorRows":0,"committedTaskNum":0,"loadedRows":0,"loadRowsRate":0,"abortedTaskNum":0,"errorRowsAfterResumed":0,"totalRows":0,"unselectedRows":0,"receivedBytesRate":0,"taskExecuteTimeMs":1}', '{}', '{}', 'ErrorReason{code=errCode = 4, msg='errCode = 2, detailMessage = Failed to get all partitions of kafka topic: test-routine-load-csv error: errCode = 2, detailMessage = Failed to get info may be Kafka properties set in job is error or no partition in this topic that should check Kafka'}', '', '', 'root', '');

Resuming the task is helpless.
What's wong with it?

[CzyerChen]

Anyone can help?

[sollhui]

It seems that connectivity issues rather than bug.

[ixzc]

can you share your fe.log file? btw, you can try restarting your cluster