dataprism/dataprism-ldk-nodejs

Dataprism逻辑开发工具包（Node.js版本）

概述

Dataprism逻辑开发工具包（Node.js版本）是用于在Dataprism平台内部开发和运行应用逻辑的工具，支持基于Kafka流的消息处理，帮助开发者快速构建平台内的业务逻辑。

使用示例

javascript
const Platform = require('@dataprism/ldk');
const platform = new Platform();

const stream = platform.getStream("my_kafka_topic");

stream.forEach(message => {
    console.log(message);
});

stream.start();

配置参数

可通过环境变量配置以下参数：

• DP_BROKER_LIST：Kafka节点列表（含端口），示例："localhost:9092"
• DP_GROUP_ID：唯一组ID，关联同一逻辑的多个实例，实现Kafka消息在组内分发
• DP_CLIENT_ID：唯一客户端ID，标识当前逻辑实例，默认使用主机名
• DP_BATCH_NUM_MESSAGES：批量发送到Kafka集群的消息数量阈值
• DP_AUTO_OFFSET_RESET：Kafka偏移量重置策略（如earliest、latest）

若在Dataprism平台运行，所有参数将由平台自动注入。

Docker部署示例

bash
docker run \
  -e DP_BROKER_LIST=localhost:9092 \
  -e DP_GROUP_ID=logic_group_demo \
  -e DP_CLIENT_ID=logic_demo_01 \
  dataprism/dataprism-ldk-nodejs