Memory leak And message loss #822
Description
in StartConsuming func:
The goroutine for obtaining messages will not terminate when the consumer error，Causing memory leaks and message loss
{{ message }}
in StartConsuming func:
The goroutine for obtaining messages will not terminate when the consumer error，Causing memory leaks and message loss