diff --git a/plugins/inputs/logstash/logstash.go b/plugins/inputs/logstash/logstash.go index 19ea01394..2d493c3d2 100644 --- a/plugins/inputs/logstash/logstash.go +++ b/plugins/inputs/logstash/logstash.go @@ -264,11 +264,11 @@ func (logstash *Logstash) gatherPluginsStats( accumulator.AddFields("logstash_plugins", failuresFields, pluginTags) } /* - The elasticsearch output produces additional stats around - bulk requests and document writes (that are elasticsearch specific). - Collect those here + The elasticsearch & opensearch output produces additional stats + around bulk requests and document writes (that are elasticsearch + and opensearch specific). Collect those below: */ - if pluginType == "output" && plugin.Name == "elasticsearch" { + if pluginType == "output" && (plugin.Name == "elasticsearch" || plugin.Name == "opensearch") { /* The "bulk_requests" section has details about batch writes into Elasticsearch