文档

Kafka兼容说明

更新时间:

流引擎的流表兼容Kafka协议,支持通过开源Kafka客户端写入数据,也支持通过Kafka生态工具将MySQL、日志等数据投递至流引擎。本文介绍通过开源Kafka客户端将数据写入流表的操作步骤。

操作步骤

  1. 获取流引擎连接地址。具体操作,请参见查看连接地址

  2. 创建流表。如何创建,请参见流表

  3. 获取Kafka Topic名称。

    Kafka Topic名称的格式为:-LINSTREAM-+ Database名+“.”+流表名。例如数据库default中一个名为t1的流表,对应的Kafka Topic的名称为-LINSTREAM-default.t1

    重要

    如果Database或流表名称中含有下划线(_),则需要将下划线替换为短横线(-)。

  4. 将流表中的数据写入Kafka Topic。具体操作,请参见通过开源Kafka客户端写入Lindorm流引擎数据

  • 本页导读 (1)