分类：kafka消费

2020
12-18

golang连接kafka消费进ES操作

1.首先初始化conf配置把kafka和ES的地址配置好还有一个日志方便查看配置信息如下用到的库是github.com/astaxie/beego/config[logs]log_level=debuglog_path="./logs/log_transfer.log"[kafka]server_addr=192.168.0.134:9092topic=nginx_log[ES]addr=http://192.168.0.134:9200/2.读取conf配置存取进结构体typeLogConfigstruct{kafkaAddrstringESAddrstringLogPathstringLogLevelstringTopicstring}v... 继续阅读 >