update logstash input kafka

dev-upgrade/elastic/logstash.yml

@@ -5,8 +5,12 @@ metadata:
 data:
   logstash.conf: |-
     input {
-      beats {
-        port => 5044
+      kafka{
+        bootstrap_servers => "10.2.0.12:30002,10.2.0.12:30003,10.2.0.12:30004"
+        topics => ["beaconfire-logback-dev","beaconfire-logback-prod"]
+        group_id => "logstash-app"
+        auto_offset_reset => "earliest"
+        codec => json
       }
     }
 
@@ -20,6 +24,9 @@ data:
         split => { "[log][file][path]" => "/" }
         add_field => { "env" => "%{[log][file][path][3]}" }
       }
+      mutate {
+        join => { "[log][file][path]" => "/" }
+      }
     }  
 
     output {