Lua Kafka使用

2021-06-26 2022-02-04

tech

a minute read (About 150 words)

Lua Kafka使用

lua-resty-kafka，Lua kafka client driver for the Openresty based on the cosocket API。需要注意的是，不同于redis和mysql 客户端，kafka客户端并不是自带的，需要自行下载发布到openresty 的lualib目录下：

1
2
3

wget https://github.com/doujiang24/lua-resty-kafka/archive/master.zip
unzip master.zip
cp -r lua-resty-kafka-master/lib/resty/kafka /usr/local/openresty/lualib/resty/

当max_buffering参数设置过大时，出现table overflow

module.kafka_producer_conf = {
    producer_type = "async",
    socket_timeout=10000,
    keepalive_size=200,
    keepalive_timeout=10000,
    flush_time = 5000,
    batch_num = 100,
    max_buffering= 5000000,
    error_handle=batch_error_handle
}

1	[error] 7692#0: *8828748 lua entry thread aborted: runtime error: table overflow

将 max_buffering调小即可

本文标题：Lua Kafka使用
本文作者：LoganShen
本文链接：https://blog.95id.com/lua-kafka.html
发布时间：2021-06-26
版权声明：本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明出处！

lua, openResty

Lua Kafka使用

Lua Kafka使用

Catalogue

Your browser is out-of-date!