golang連接kafka消費進ES

1.首先初始化conf配置把kafka和ES的地址配置好還有一個日誌方便查看 配置信息如下 用到的庫是 github.com/astaxie/beego/config [logs] log_level = debug log_path = "./logs/log_transfer.log" [kafka] server_addr = 192.168.0.134:9092 topic = nginx

>>阅读原文<<