Logstash消費kafka同步數據到elasticsearch的配置文件

input{ kafka{ bootstrap_servers => ["192.169.160.25:7091,192.169.160.26:7092,192.169.160.27:7093,192.169.160.28:7094,192.169.160.29:7095"] #kafka的地址,集羣有逗號隔開 client_id => "cpm_addUser"
相關文章
相關標籤/搜索