KAFKA-13166 Fix missing ControllerApis error handling (#12403)
Makes all ControllerApis request handlers return a `CompletableFuture[Unit]`. Also adds an additional completion stage which ensures we capture errors thrown during response building.
Reviewed-by:
Colin P. McCabe <cmccabe@apache.org>
显示
- core/src/main/scala/kafka/server/AclApis.scala 23 个添加, 9 个删除core/src/main/scala/kafka/server/AclApis.scala
- core/src/main/scala/kafka/server/ControllerApis.scala 71 个添加, 50 个删除core/src/main/scala/kafka/server/ControllerApis.scala
- core/src/test/scala/unit/kafka/server/ControllerApisTest.scala 30 个添加, 0 个删除...src/test/scala/unit/kafka/server/ControllerApisTest.scala
加载中
想要评论请 注册 或 登录