Function NewCooperativeActiveStickyBalancer

pkg/ingest/balancer.go:34–39

NewCooperativeActiveStickyBalancer creates a balancer that combines Kafka's cooperative sticky balancing with partition ring awareness. It works by: 1. Using the partition ring to determine which partitions are "active" (i.e. should be processed) 2. Filtering out inactive partitions from member ass

(partitionRing ring.PartitionRingReader)

// rebalancing when the set of active partitions changes. This ensures optimal partition distribution
// as the active partition set evolves.
func NewCooperativeActiveStickyBalancer(partitionRing ring.PartitionRingReader) kgo.GroupBalancer {
	return &cooperativeActiveStickyBalancer{
		GroupBalancer: kgo.CooperativeStickyBalancer(),
		partitionRing: partitionRing,
	}
}

func (*cooperativeActiveStickyBalancer) ProtocolName() string {
	return "cooperative-active-sticky"