diff --git a/cmd/otel-agent/config/agent_config.go b/cmd/otel-agent/config/agent_config.go index e2c77696787f1b..32830518db4169 100644 --- a/cmd/otel-agent/config/agent_config.go +++ b/cmd/otel-agent/config/agent_config.go @@ -73,6 +73,7 @@ func NewConfigComponent(ctx context.Context, uris []string) (config.Component, e // Log configs pkgconfig.Set("logs_enabled", true, pkgconfigmodel.SourceLocalConfigProcess) + pkgconfig.Set("logs_config.force_use_http", true, pkgconfigmodel.SourceLocalConfigProcess) pkgconfig.Set("logs_config.logs_dd_url", ddc.Logs.Endpoint, pkgconfigmodel.SourceLocalConfigProcess) pkgconfig.Set("logs_config.batch_wait", ddc.Logs.BatchWait, pkgconfigmodel.SourceLocalConfigProcess) pkgconfig.Set("logs_config.use_compression", ddc.Logs.UseCompression, pkgconfigmodel.SourceLocalConfigProcess) diff --git a/cmd/otel-agent/config/agent_config_test.go b/cmd/otel-agent/config/agent_config_test.go index a3cfbb5d69c25a..9d65f35c1846f7 100644 --- a/cmd/otel-agent/config/agent_config_test.go +++ b/cmd/otel-agent/config/agent_config_test.go @@ -26,6 +26,7 @@ func TestAgentConfig(t *testing.T) { assert.Equal(t, "test.logs.com", c.Get("logs_config.logs_dd_url")) assert.Equal(t, 10, c.Get("logs_config.batch_wait")) assert.Equal(t, true, c.Get("logs_config.use_compression")) + assert.Equal(t, true, c.Get("logs_config.force_use_http")) assert.Equal(t, 1, c.Get("logs_config.compression_level")) assert.Equal(t, "https://trace.agent.datadoghq.eu", c.Get("apm_config.apm_dd_url")) assert.Equal(t, map[string]string{"io.opentelemetry.javaagent.spring.client": "spring.client"}, c.Get("otlp_config.traces.span_name_remappings")) @@ -49,6 +50,7 @@ func TestAgentConfigDefaults(t *testing.T) { assert.Equal(t, "https://agent-http-intake.logs.datadoghq.com", c.Get("logs_config.logs_dd_url")) assert.Equal(t, 5, c.Get("logs_config.batch_wait")) assert.Equal(t, true, c.Get("logs_config.use_compression")) + assert.Equal(t, true, c.Get("logs_config.force_use_http")) assert.Equal(t, 6, c.Get("logs_config.compression_level")) assert.Equal(t, "https://trace.agent.datadoghq.com", c.Get("apm_config.apm_dd_url")) assert.Equal(t, false, c.Get("apm_config.receiver_enabled"))