MINOR: Fix authentication check and do some small refactoring in...
MINOR: Fix authentication check and do some small refactoring in ClusterLinkConnectionChecker (#7161)
显示
- core/src/main/scala/kafka/server/link/ClusterLinkConnectionChecker.scala 60 个添加, 69 个删除...cala/kafka/server/link/ClusterLinkConnectionChecker.scala
- core/src/main/scala/kafka/server/link/ClusterLinkManager.scala 21 个添加, 0 个删除...src/main/scala/kafka/server/link/ClusterLinkManager.scala
- core/src/test/scala/unit/kafka/server/link/ClusterLinkConnectionCheckerTest.scala 72 个添加, 32 个删除.../kafka/server/link/ClusterLinkConnectionCheckerTest.scala
加载中
想要评论请 注册 或 登录