KGLOBAL-1777 retry finding a link coordinator instead (#7176)
* KGLOBAL-1777 retry finding a link coordinator instead of giving up immediately * KGLOBAL-1777 retry finding a link coordinator instead of giving up immediately * KGLOBAL-1777 retry finding a link coordinator instead of giving up immediately * KGLOBAL-1777 wait for link metadata to be created to ensure link coordinator will exists * removed redundant check as per review comments * increased brokerCount=2 else test would complain about not being able to replicate metadata topic to 2 times
显示
- core/src/test/scala/integration/kafka/link/AbstractClusterLinkIntegrationTest.scala 3 个添加, 0 个删除...ation/kafka/link/AbstractClusterLinkIntegrationTest.scala
- core/src/test/scala/integration/kafka/link/ClusterLinkIntegrationTest.scala 1 个添加, 13 个删除...a/integration/kafka/link/ClusterLinkIntegrationTest.scala
- core/src/test/scala/integration/kafka/link/ClusterLinkPolicyTest.scala 4 个添加, 4 个删除.../scala/integration/kafka/link/ClusterLinkPolicyTest.scala
- core/src/test/scala/integration/kafka/link/ClusterLinkTestHarness.scala 22 个添加, 4 个删除...scala/integration/kafka/link/ClusterLinkTestHarness.scala
加载中
想要评论请 注册 或 登录