Merge pull request #160 from dkeven/correctesparams

Fix the incorrect keys of the es output plugin
fluent · Oct 31, 2021 · dcdfa8a · dcdfa8a
2 parents 4b96fcc + 7af22a2
commit dcdfa8a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/api/fluentbitoperator/v1alpha2/plugins/output/elasticsearch_types.go b/api/fluentbitoperator/v1alpha2/plugins/output/elasticsearch_types.go
@@ -153,10 +153,10 @@ func (es *Elasticsearch) Params(sl plugins.SecretLoader) (*params.KVs, error) {
 		kvs.Insert("HTTP_Passwd", pwd)
 	}
 	if es.Index != "" {
-		kvs.Insert("Host", es.Index)
+		kvs.Insert("Index", es.Index)
 	}
 	if es.Type != "" {
-		kvs.Insert("Host", es.Type)
+		kvs.Insert("Type", es.Type)
 	}
 	if es.LogstashFormat != nil {
 		kvs.Insert("Logstash_Format", fmt.Sprint(*es.LogstashFormat))