Tencent / TubeMQ

TubeMQ has been donated to the Apache Software Foundation and renamed to InLong, please visit the new Apache repository: https://github.com/apache/incubator-inlong
https://inlong.apache.org/
2.02k stars 391 forks source link

Optimization: adjust the heartbeat authentication failure processing #132

Closed gosonzhang closed 4 years ago

gosonzhang commented 4 years ago

It is rare to encounter authentication failure during heartbeat,and the current implementation needs to be refined: the producer should not continue to register, reduce the heartbeat frequency, reduce the processing pressure of the master before the problem is solved; the consumer end releases the authentication failed partition and avoids authentication failure and unable to consume problems


心跳时遇到认证失败比较少见,不过当前的实现需要再细化:producer不应该继续注册,同时降低心跳频度,减少问题没有解决前对Master的处理压力;consumer端释放认证失败的分区,避免认证失败并且无法消费问题