If we get a message from a topic that we have not configured we will push an error channel into the results channel that will never have a message pushed into it. This will halt processing. We need to close the error channel in addition to logging the message about the bad topic/message mapping.
If we get a message from a topic that we have not configured we will push an error channel into the results channel that will never have a message pushed into it. This will halt processing. We need to close the error channel in addition to logging the message about the bad topic/message mapping.
https://github.com/brave-intl/challenge-bypass-server/blob/17fec6895e373d00b87317650c70bfda128784a9/kafka/main.go#L200