流引擎的流表兼容Kafka协议，支持通过开源Kafka客户端写入数据，也支持通过Kafka生态工具将MySQL、日志等数据投递至流引擎。本文介绍通过开源Kafka客户端将数据写入流表的操作步骤。
操作步骤
获取流引擎连接地址。具体操作，请参见查看连接地址。
创建流表。如何创建，请参见流表。
获取Kafka Topic名称。
Kafka Topic名称的格式为：
-LINSTREAM-+ Database名+“.”+流表名。例如数据库default中一个名为t1的流表，对应的Kafka Topic的名称为-LINSTREAM-default.t1。重要如果Database或流表名称中含有下划线（_），则需要将下划线替换为短横线（-）。
将流表中的数据写入Kafka Topic。具体操作，请参见通过开源Kafka客户端写入Lindorm流引擎数据。
该文章对您有帮助吗？