Commit d0350d1
committed
kgo: fix sharded-request "minor" data race introduced in 1.20.3
Low impact, the sharded request "avoid broker" logic introduced in
1.20.3 did not create loop-local variables, meaning the goroutines
started in each iteration of the loop all shared the same integer.
Closes #1168.1 parent 566201c commit d0350d1
1 file changed
Lines changed: 7 additions & 4 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
2482 | 2482 | | |
2483 | 2483 | | |
2484 | 2484 | | |
2485 | | - | |
2486 | | - | |
2487 | | - | |
| 2485 | + | |
| 2486 | + | |
| 2487 | + | |
| 2488 | + | |
| 2489 | + | |
| 2490 | + | |
| 2491 | + | |
2488 | 2492 | | |
2489 | 2493 | | |
2490 | 2494 | | |
| |||
2494 | 2498 | | |
2495 | 2499 | | |
2496 | 2500 | | |
2497 | | - | |
2498 | 2501 | | |
2499 | 2502 | | |
2500 | 2503 | | |
| |||
0 commit comments