Support for hash.random (#142)

pcfens · Nov 20, 2017 · f38bb37 · f38bb37
1 parent 9b4a45e
commit f38bb37
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/templates/filebeat.yml.erb b/templates/filebeat.yml.erb
@@ -320,6 +320,9 @@ output.kafka:
  <%- if @filebeat_config['output']['kafka']['partition']['hash']['reachable_only'] != nil -%>
  reachable_only: <%= @filebeat_config['output']['kafka']['partition']['hash']['reachable_only'] %>
  <%- end -%>
+ <%- if @filebeat_config['output']['kafka']['partition']['hash']['random'] != nil -%>
+ random: <%= @filebeat_config['output']['kafka']['partition']['hash']['random'] %>
+ <%- end -%>
  <%- if @filebeat_config['output']['kafka']['partition']['hash']['hash'] != nil -%>
  hash:
  <%- @filebeat_config['output']['kafka']['partition']['hash']['hash'].each do |value| -%>