Collapsing redundant upstream API calls in a Kafka consumer with Go’s singleflight, applied to concurrent user-change events against a shared rate-limited API.