diff --git a/internal/beater/beater.go b/internal/beater/beater.go
index 5e04cf4bb95..f8278da7514 100644
--- a/internal/beater/beater.go
+++ b/internal/beater/beater.go
@@ -779,14 +779,13 @@ func (s *Runner) newDocappenderConfig(tracer *apm.Tracer, memLimit float64) (
 		scalingCfg.Disabled = !*enabled
 	}
 	cfg := docappenderConfig(docappender.Config{
-		CompressionLevel:  esConfig.CompressionLevel,
-		FlushBytes:        flushBytes,
-		FlushInterval:     esConfig.FlushInterval,
-		Tracer:            tracer,
-		MaxRequests:       esConfig.MaxRequests,
-		Scaling:           scalingCfg,
-		Logger:            zap.New(s.logger.Core(), zap.WithCaller(true)),
-		RequireDataStream: true,
+		CompressionLevel: esConfig.CompressionLevel,
+		FlushBytes:       flushBytes,
+		FlushInterval:    esConfig.FlushInterval,
+		Tracer:           tracer,
+		MaxRequests:      esConfig.MaxRequests,
+		Scaling:          scalingCfg,
+		Logger:           zap.New(s.logger.Core(), zap.WithCaller(true)),
 	}, memLimit, s.logger)
 	if cfg.MaxRequests != 0 {
 		esConfig.MaxIdleConnsPerHost = cfg.MaxRequests
diff --git a/internal/beater/beater_test.go b/internal/beater/beater_test.go
index 36c700d75f5..714f7a5042f 100644
--- a/internal/beater/beater_test.go
+++ b/internal/beater/beater_test.go
@@ -180,7 +180,6 @@ func TestRunnerNewDocappenderConfig(t *testing.T) {
 			assert.Equal(t, docappender.Config{
 				Logger:             zap.New(r.logger.Core(), zap.WithCaller(true)),
 				CompressionLevel:   5,
-				RequireDataStream:  true,
 				FlushInterval:      time.Second,
 				FlushBytes:         1024 * 1024,
 				MaxRequests:        c.wantMaxRequests,
@@ -210,7 +209,6 @@ func TestRunnerNewDocappenderConfig(t *testing.T) {
 			assert.Equal(t, docappender.Config{
 				Logger:             zap.New(r.logger.Core(), zap.WithCaller(true)),
 				CompressionLevel:   5,
-				RequireDataStream:  true,
 				FlushInterval:      2 * time.Second,
 				FlushBytes:         500 * 1024,
 				MaxRequests:        50,