查看Routine Load
SHOW ROUTINE LOAD -- 有以下4种State: -- * NEED_SCHEDULE:作业等待被调度 -- * RUNNING:作业运行中 -- * PAUSED:作业被暂停 -- * STOPPED:作业已结束 -- * CANCELLED:作业已取消 RESUME ROUTINE LOAD FOR rl_test01.rl_test01
发送测试Kafka测试数据
./bin/kafka-console-producer.sh --broker-list doris:9092 --topic rl_test01 # 测试数据如下
查看Doris结果数据
select * from rl_test01
常见问题
Failed to get all partitions of kafka topic
异常详情: detailMessage = Failed to get all partitions of kafka topic: rl_test01
可能原因:
机房访问不了本地host
kafka未提前设置自动创建topic
current error rows is more than max error num
异常详情: ErrorReason{code=errCode = 102, msg=‘current error rows is more than max error num’}
max_error_number:默认为0,即不允许有错误行
Kafka的安装部署及Apache Doris的Routine Load快速体验至此结束,体验过程中若遇到问题欢迎留言交流