这里使用的是kafka插件是doujiang大佬的https://github.com/doujiang24/lua-resty-kafka，版本为v0.2.0。
应用场景
在nginx转发中，记录非200请求的信息，遂打算在log_by_lua*中整合信息并发送kafka消息。下面附上openresty不同阶段的说明：
set_by_lua*: 流程分支处理判断变量初始化
rewrite_by_lua*: 转发、重定向、缓存等功能(例如特定请求代理到外网)
access_by_lua*: IP 准入、接口权限等情况集中处理(例如配合 iptable 完成简单防火墙)
content_by_lua*: 内容生成
header_filter_by_lua*: 响应头部过滤处理(例如添加头部信息)
body_filter_by_lua*: 响应体过滤处理(例如完成应答内容统一成大写)
log_by_lua*: 会话完成后本地异步完成日志记录(日志可以记录在本地，还可以同步到其他机器)
摘自：执行阶段概念
发现问题
实际使用中发现，lua-resty-kafka中使用的ngx.http.tcp由于nginx内核限制的问题，API不能使用，报错如下：
又尝试了一下header_filter_by_lua和body_filter_by_lua，也都是不能使用的，看到有使用ngx.time.at相关的，但是没有找到实践方案不知该如何尝试，遂放弃
解决
在content_by_lua*阶段也尝试一下，可以，能判断出ngx.status，但是有新的报错如下：
这个应该是kakfa节点的问题。