As configured, the error channel will exist until a recipient reads the channel. Instead, allow exactly one result to be buffered. This will allow cleanup of resources related to processing in the event that the reader of the error channel is delayed in receiving.
As configured, the error channel will exist until a recipient reads the channel. Instead, allow exactly one result to be buffered. This will allow cleanup of resources related to processing in the event that the reader of the error channel is delayed in receiving.
https://github.com/brave-intl/challenge-bypass-server/blob/17fec6895e373d00b87317650c70bfda128784a9/kafka/main.go#L173