feat: add require datastreams to bulk index requests

kruskall · Jun 11, 2024 · 272c014 · 272c014
1 parent dbf7960
commit 272c014
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/internal/beater/beater.go b/internal/beater/beater.go
@@ -691,13 +691,14 @@ func (s *Runner) newFinalBatchProcessor(
 		scalingCfg.Disabled = !*enabled
 	}
 	opts := 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)),
+		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,
 	}
 	opts = docappenderConfig(opts, memLimit, s.logger)
 	appender, err := docappender.New(client, opts)