diff --git a/helk-logstash/pipeline/02-kafka-input.conf b/helk-logstash/pipeline/02-kafka-input.conf index 5f2f89f..e86d3ba 100644 --- a/helk-logstash/pipeline/02-kafka-input.conf +++ b/helk-logstash/pipeline/02-kafka-input.conf @@ -6,7 +6,7 @@ input { kafka { - bootstrap_servers => "helk-kafka-broker:9092" + bootstrap_servers => "helk-kafka-broker:9092,helk-kafka-broker2:9093" topics => ["winlogbeat"] decorate_events => true codec => "json"