songlq

kafka handle

1

kafkamq 提供一种插件机制：将数据（[]byte）通过 HTTP 发送到外部handle，经过处理后再通过response返回行协议的json格式数据。实现定制化数据。 增加如下配置：（以最终配置为准） - `http url` string - `message_points` int 一次发送的消息点数 - `debug` bool 值, 当开启debug功能， `message_points` 则无效，如果开启debug模式，则将原始byte数据发送，不再进行消息合并。 - `threads` int 多线程工作 - `is_response_point` 是否将行协议数据发送回来 - `pipeline` 脚本...