KGLOBAL-1724: Wrong source topic name in DescribeMirrorsResponse. (#6964)
This happens when cluster link prefix is used. Also rename mirrorTopic to sourceTopic in MirrorTopicDescription to avoid confusion.
显示
- ce-broker-plugins/src/test/java/io/confluent/kafka/link/integration/MultiTenantClusterLinkTest.java 4 个添加, 4 个删除...nt/kafka/link/integration/MultiTenantClusterLinkTest.java
- clients/src/main/java/org/apache/kafka/clients/admin/MirrorTopicDescription.java 25 个添加, 14 个删除...rg/apache/kafka/clients/admin/MirrorTopicDescription.java
- clients/src/main/resources/common/message/DescribeMirrorsResponse.json 1 个添加, 1 个删除...ain/resources/common/message/DescribeMirrorsResponse.json
- core/src/main/scala/kafka/admin/MirrorCommand.scala 1 个添加, 1 个删除core/src/main/scala/kafka/admin/MirrorCommand.scala
- core/src/main/scala/kafka/server/KafkaApis.scala 1 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaApis.scala
- core/src/main/scala/kafka/server/link/ClusterLinkAdminManager.scala 22 个添加, 3 个删除...ain/scala/kafka/server/link/ClusterLinkAdminManager.scala
- core/src/test/scala/integration/kafka/link/AbstractClusterLinkIntegrationTest.scala 1 个添加, 1 个删除...ation/kafka/link/AbstractClusterLinkIntegrationTest.scala
- core/src/test/scala/integration/kafka/link/ClusterLinkIntegrationTest.scala 1 个添加, 3 个删除...a/integration/kafka/link/ClusterLinkIntegrationTest.scala
- core/src/test/scala/unit/kafka/admin/MirrorCommandTest.scala 3 个添加, 3 个删除core/src/test/scala/unit/kafka/admin/MirrorCommandTest.scala
加载中
想要评论请 注册 或 登录