Merge branch 'master' into mobile-fields

Author: jalvz

cmd/root.go

@@ -83,8 +83,9 @@ var libbeatConfigOverrides = func() []cfgfile.ConditionalOverride {
 				return common.MustNewConfigFrom(map[string]interface{}{
 					"output": map[string]interface{}{
 						"elasticsearch": map[string]interface{}{
-							"worker":        cloudMatrix[cap].worker,
-							"bulk_max_size": cloudMatrix[cap].bulkMaxSize,
+							"compression_level": 5, //default to medium compression on cloud
+							"worker":            cloudMatrix[cap].worker,
+							"bulk_max_size":     cloudMatrix[cap].bulkMaxSize,
 						},
 					},
 					"queue": map[string]interface{}{

cmd/root_test.go

@@ -45,6 +45,10 @@ func TestCloudEnv(t *testing.T) {
 	require.NoError(t, err)
 	assert.Equal(t, int64(5), workers)
 
+	compression, err := cfg.Int("output.elasticsearch.compression_level", -1)
+	require.NoError(t, err)
+	assert.Equal(t, int64(5), compression)
+
 	// bad cloud environment value
 	os.Setenv(cloudEnv, "123")
 	settings = DefaultSettings()