Kafka

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

支持版本

Kafka 2.3.x

使用限制

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

准备工作

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

下一步

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