【已解决】采用Doris-Kafka-Connector插件无法将数据写入Doris

Viewed 90

测试环境:Kafka Connect集群,日志为Debezium的PostgresConnector产生,avro格式;Doris版本为 doris-2.0.2-rc05;

将下载的jar包,放入connect-distributed.properties指定的plugin.path中,重启后插件生效,kafka集群连接器插件列表返回如下信息:
image.png

按照文档提示,正常可以创建connector,配置信息如下:
image.png

发送消息到Kafka后,完整消息体格式如下:
image.png

connect.log中信息如下:
image.png

be.INFO中信息如下:
image.jpg

2 Answers

【问题状态】处理中
【问题处理】内部定位中,有进展会更新回帖