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

inlet/kafka: be more lenient about test for load balancing

Browse Source 
Require just a few messages in each partition.
This commit is contained in:
Vincent Bernat
2025-12-02 10:04:22 +01:00
parent a3c6ccd517
commit 3e400a8ddd
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
inlet/kafka/root_test.go
View File

@@ -163,7 +163,7 @@ func TestLoadBalancingAlgorithm(t *testing.T) {
switch algo { switch algo {
case LoadBalanceRandom: case LoadBalanceRandom:
for p, count := range messages { for p, count := range messages {
if count > total/len(messages)*6/10 && count < total/len(messages)*14/10 { if count > total/len(messages)*2/10 && count < total/len(messages)*18/10 {
expected[p] = count expected[p] = count
} else { } else {
expected[p] = total / len(messages) expected[p] = total / len(messages)