chore: Use Kafka round-robin balancer for index-builder (#19574)

3 months ago · ea2b4d0f84
parent f46ef0eb7c
commit ea2b4d0f84
1 changed files with 1 additions and 0 deletions
--- a/pkg/dataobj/index/builder.go
+++ b/pkg/dataobj/index/builder.go
@ -176,6 +176,7 @@ func NewIndexBuilder(
 		kgo.InstanceID(instanceID),
 		kgo.SessionTimeout(3*time.Minute),
 		kgo.ConsumerGroup(indexConsumerGroup),
+		kgo.Balancers(kgo.RoundRobinBalancer()),
 		kgo.RebalanceTimeout(5*time.Minute),
 		kgo.DisableAutoCommit(),
 		kgo.OnPartitionsRevoked(s.handlePartitionsRevoked),