Skip to content

Commit

Permalink
Update kafka output metadata fetch (#12738)
Browse files Browse the repository at this point in the history
Change default metadata request configuration in the kafka output to
only collect metadata of topics we publish to.
  • Loading branch information
Steffen Siering authored Jul 2, 2019
1 parent d4589ed commit 0316e70
Show file tree
Hide file tree
Showing 15 changed files with 27 additions and 26 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.next.asciidoc
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d
- Update to Golang 1.12.1. {pull}11330[11330]
- Update to Golang 1.12.4. {pull}11782[11782]
- Update to ECS 1.0.1. {pull}12284[12284] {pull}12317[12317]
- Default of output.kafka.metadata.full is set to false by now. This reduced the amount of metadata to be queried from a kafka cluster. {pull}12738[12738]

*Auditbeat*

Expand Down
4 changes: 2 additions & 2 deletions auditbeat/auditbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -668,8 +668,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions filebeat/filebeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -1372,8 +1372,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions heartbeat/heartbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -812,8 +812,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions journalbeat/journalbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -608,8 +608,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions libbeat/_meta/config.reference.yml.tmpl
Original file line number Diff line number Diff line change
Expand Up @@ -556,8 +556,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
2 changes: 1 addition & 1 deletion libbeat/docs/outputconfig.asciidoc
Original file line number Diff line number Diff line change
Expand Up @@ -1142,7 +1142,7 @@ brokers, topics, partition, and active leaders to use for publishing.

*`full`*:: Strategy to use when fetching metadata, when this option is `true`, the client will maintain
a full set of metadata for all the available topics, if the this option is set to `false` it will only refresh the
metadata for the configured topics. The default is true.
metadata for the configured topics. The default is false.

*`retry.max`*:: Total number of metadata update retries when cluster is in middle of leader election. The default is 3.

Expand Down
2 changes: 1 addition & 1 deletion libbeat/outputs/kafka/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ func defaultConfig() kafkaConfig {
Backoff: 250 * time.Millisecond,
},
RefreshFreq: 10 * time.Minute,
Full: true,
Full: false,
},
KeepAlive: 0,
MaxMessageBytes: nil, // use library default
Expand Down
4 changes: 2 additions & 2 deletions metricbeat/metricbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -1326,8 +1326,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions packetbeat/packetbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -1045,8 +1045,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions winlogbeat/winlogbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -589,8 +589,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions x-pack/auditbeat/auditbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -719,8 +719,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions x-pack/filebeat/filebeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -1520,8 +1520,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions x-pack/metricbeat/metricbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -1421,8 +1421,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down
4 changes: 2 additions & 2 deletions x-pack/winlogbeat/winlogbeat.reference.yml
Original file line number Diff line number Diff line change
Expand Up @@ -601,8 +601,8 @@ output.elasticsearch:
# Refresh metadata interval. Defaults to every 10 minutes.
#refresh_frequency: 10m

# Strategy for fetching the topics metadata from the broker. Default is true.
#full: true
# Strategy for fetching the topics metadata from the broker. Default is false.
#full: false

# The number of concurrent load-balanced Kafka output workers.
#worker: 1
Expand Down

0 comments on commit 0316e70

Please sign in to comment.