mlua-kafka 1.0.0

An rdkafka-based implementation of LuaRocks chensoft/kafka for mlua.
1
2
3
4
5
6
7
8
9

use super::Producer;
use mlua::{Error, Lua};
use std::time::Duration;

pub(super) fn handle(_lua: &Lua, producer: &Producer, timeout_ms: u64) -> Result<(), Error> {
    let dur = Duration::from_millis(timeout_ms);
    producer.producer.poll(dur);
    Ok(())
}