johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-11 22:14:02 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

outlet/kafka: log a message when increasing/decreasing workers
Some checks failed
CI / 🤖 Check dependabot status (push) Has been cancelled
Details
CI / 🐧 Test on Linux (${{ github.ref_type == 'tag' }}, misc) (push) Has been cancelled
Details
CI / 🐧 Test on Linux (coverage) (push) Has been cancelled
Details
CI / 🐧 Test on Linux (regular) (push) Has been cancelled
Details
CI / ❄️ Build on Nix (push) Has been cancelled
Details
CI / 🍏 Build and test on macOS (push) Has been cancelled
Details
CI / 🧪 End-to-end testing (push) Has been cancelled
Details
CI / 🔍 Upload code coverage (push) Has been cancelled
Details
CI / 🔬 Test only Go (push) Has been cancelled
Details
CI / 🔬 Test only JS (${{ needs.dependabot.outputs.package-ecosystem }}, 20) (push) Has been cancelled
Details
CI / 🔬 Test only JS (${{ needs.dependabot.outputs.package-ecosystem }}, 22) (push) Has been cancelled
Details
CI / 🔬 Test only JS (${{ needs.dependabot.outputs.package-ecosystem }}, 24) (push) Has been cancelled
Details
CI / ⚖️ Check licenses (push) Has been cancelled
Details
CI / 🐋 Build Docker images (push) Has been cancelled
Details
CI / 🐋 Tag Docker images (push) Has been cancelled
Details
CI / 🚀 Publish release (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Vincent Bernat
2025-11-06 07:52:01 +01:00
parent 85255d3507
commit a336c42c5b
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
outlet/kafka/scaler.go
View File

@@ -98,6 +98,7 @@ func (c *realComponent) startScaler() chan<- ScaleRequest {
targetWorkers := state.nextWorkerCount(request, c.config.MinWorkers, c.config.MaxWorkers)
if targetWorkers > currentWorkers {
c.r.Info().Msgf("increase number of workers from %d to %d", currentWorkers, targetWorkers)
for i := currentWorkers; i < targetWorkers; i++ {
if err := c.startOneWorker(); err != nil {
c.r.Err(err).Msg("cannot spawn a new worker")
@@ -115,6 +116,7 @@ func (c *realComponent) startScaler() chan<- ScaleRequest {
targetWorkers := state.nextWorkerCount(request, c.config.MinWorkers, c.config.MaxWorkers)
if targetWorkers < currentWorkers {
c.r.Info().Msgf("decrease number of workers from %d to %d", currentWorkers, targetWorkers)
for i := currentWorkers; i > targetWorkers; i-- {
c.stopOneWorker()
}