跳到主要内容
版本:3.x

Kafka

Apache Kafka 是一个分布式数据流处理平台,可以实时发布、订阅、存储和处理数据流。在创建 Kafka 连接前,您需要在跟随本文完成前置准备工作,完成操作后即可创建连接并在数据复制/开发任务中使用该数据源。

支持版本

Kafka 2.3.x

使用限制

  • 仅支持 JSON Object 字符串的消息格式,例如:{"id":1, "name": "张三"}
  • 消息推送实现为 At least once,消费端需要设计幂等。

准备工作

  1. 登录 Kafka 所属设备,完成 Topic 的创建,相关方法,见 Kafka 快速入门
  2. 确认加密方式,如开启了 kerberos 认证,您还需要提前准备好密钥、配置等文件。

下一步

至此,已完成相关准备工作,接下来,您可以连接 Kafka 数据源