mlua-kafka

为 lua-kafka 和 mlua 实现的 Rust-native 版本。

安装

使用 MLua 的功能之一将此库添加到您的 Rust 项目中：[lua51, lua52, lua53, lua54, luajit, luajit52]。

$ cargo add mlua-kafka --features luajit

使用

use mlua::Lua;

let lua = Lua::new();
mlua_kafka::preload(&lua);
let script = r#"
    local settings = {
        ['bootstrap.servers'] = '127.0.0.1:9092',
    }
    local producer = require('kafka').producer(settings)
    producer:produce('topic', 'mykey', 'myvalue')
    producer:flush(100)
"#;
lua.load(script).exec()?;

集成测试

$ KAFKA_BROKERS=127.0.0.1:9092 KAFKA_TOPIC=mytopic cargo test