文档首页> > 开发指南> Kafka开发指南> Lua SDK

Lua SDK

更新时间: 2018-11-21 21:09

本节以Linux系统为例介绍Lua客户端如何连接DMS服务的Kafka队列,获取相关配置信息请参考准备环境章节。

DMS服务兼容Kafka原生API,相关调用方法请参考Kafka 官网说明

客户端环境搭建

  1. 下载SDK包

    解压后获取kafka-dms-lua.tar.gz文件。

  2. 安装luajit工具。

    执行如下命令检查是否有luajit工具。

    luajit -v

    如果没有luajit,需要安装luajit。
    • ubuntu操作系统:
      • 执行apt-cache search luajit命令检查软件仓库中是否有luajit。如没有,请自行配置软件仓库的地址。
      • 执行apt-get install luajit命令安装luajit。
    • suse操作系统:
      • 执行zypper search luajit命令检查软件仓库中是否有luajit。如没有,请自行配置软件仓库的地址。
      • 执行zypper install luajit命令安装luajit。
    • centos/redhat操作系统:
      • yum search luajit
      • yum install luajit

  3. 解压缩kafka-dms-lua.tar.gz

    以下假设解压目录为{DMSPATH}。

  4. 拷贝kafka依赖到本地的lib库中。

    cp {DMSPATH}/kafka-dms-lua/librdkafka/lib/* /usr/lib/ -R

  5. 修改example_dms.lua中的配置参数。

    cd {DMSPATH}/kafka-dmslua/luadms

    vi example_dms.lua

    修改如下配置项:

    local BROKERS_ADDRESS = { "broker" }
    local TOPIC_NAME = "your kafka topic"
    
    config["sasl.project.id"]="your projectId"
    config["sasl.access.key"]="your ak"
    config["sasl.security.key"]="your sk"
    表1 参数说明

    参数

    说明

    获取方式

    BROKERS_ADDRESS

    配置为Kafka的endpoint地址。

    请参考准备环境

    TOPIC_NAME

    配置为Kafka Topic的id。

    sasl.project.id

    项目 ID。

    sasl.access.key

    租户AK。

    security.key

    租户SK。

运行示例

  1. 执行如下命令进行生产消息。

    luajit example_dms.lua

    说明:该示例命令将会自动发送10条消息到Kafka队列中。

示例代码

生产消息

for i = 0,10 do
    producer:produce(topic, KAFKA_PARTITION_UA, "this is test message"..tostring(i))
end

while producer:outq_len() ~= 0 do
    producer:poll(10)
end
 

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

在文档使用中是否遇到以下问题







请至少选择或填写一项反馈信息

字符长度不能超过100

反馈内容不能为空!

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区
点我,12·12惊喜等着你哦~