Closed howlshadow closed 6 months ago
测试环境:Kafka Connect集群,日志为Debezium的PostgresConnector产生,avro格式;Doris版本为 doris-2.0.2-rc05;
将下载的jar包,放入connect-distributed.properties指定的plugin.path中,重启后插件生效,kafka集群连接器插件列表返回如下信息:
按照文档提示,正常可以创建connector,配置信息如下:
发送消息到Kafka后,完整消息体格式如下:
connect.log中信息如下:
be.INFO中信息如下:
https://github.com/apache/doris-kafka-connector/pull/11 https://github.com/apache/doris-kafka-connector/pull/12
测试环境:Kafka Connect集群,日志为Debezium的PostgresConnector产生,avro格式;Doris版本为 doris-2.0.2-rc05;
将下载的jar包,放入connect-distributed.properties指定的plugin.path中,重启后插件生效,kafka集群连接器插件列表返回如下信息:
按照文档提示,正常可以创建connector,配置信息如下:
发送消息到Kafka后,完整消息体格式如下:
connect.log中信息如下:
be.INFO中信息如下: