filebeat->kafka没反应。

先放配置文件

filebeat.prospectors:

- 

    paths : 

        - /home/../login/*.log 

    input_type: log

    fields:

        logtype: login

    encoding : GBK

    scan_frequency: 60s

output.kafka:

    hosts: ["kafkaServer:9092"]

    topic: "service-login"

    enable: true

input {

	kafka{

		bootstrap_servers => "127.0.0.1:9092"

		topics => "service-login"

	}

}



filter {...

}



output {

	if [fields][logtype] == "login"{

		# 输出进行格式化，采用Ruby库来解析日志   

		stdout { 

			codec => rubydebug 

		} 

		elasticsearch{

		 	hosts=>["esServer:9200"]

		 	index=>'log-%{[SystemName]}-login-%{+YYYY.MM}'

		}

	}

	

}