Skip to content

Commit 982e238

Browse files
support output.elasticsearch.max_requests (#8055)
make the number of bulk requests in the modelindexer configurable via `output.elasticsearch.max_requests`
1 parent b6cbc7d commit 982e238

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

beater/beater.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -677,6 +677,7 @@ func (s *serverRunner) newFinalBatchProcessor(
677677
*elasticsearch.Config `config:",inline"`
678678
FlushBytes string `config:"flush_bytes"`
679679
FlushInterval time.Duration `config:"flush_interval"`
680+
MaxRequests int `config:"max_requests"`
680681
}
681682
esConfig.FlushInterval = time.Second
682683
esConfig.Config = elasticsearch.DefaultConfig()
@@ -701,6 +702,7 @@ func (s *serverRunner) newFinalBatchProcessor(
701702
FlushBytes: flushBytes,
702703
FlushInterval: esConfig.FlushInterval,
703704
Tracer: s.tracer,
705+
MaxRequests: esConfig.MaxRequests,
704706
})
705707
if err != nil {
706708
return nil, nil, err

changelogs/head.asciidoc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ https://github.com/elastic/apm-server/compare/8.2\...main[View commits]
2020
[float]
2121
==== Added
2222
- System, process, and well-defined runtime metrics are now sent to the shared `metrics-apm.internal-<namespace>` data stream {pull}7882[7882]
23+
- Number of parallel bulk requests are now configurable via `output.elasticsearch.max_requests` {pull}8055[8055]
2324

2425

2526
// Added but still being debugged

0 commit comments

Comments
 (0)