派生自
oss-mirrors / ICV / kafka
源项目有可见性限制。
Stanislav Kozlovski
编辑于
The test would sometimes fail with an UnknownPartitionException due to the async metadata propagation and the DescribeTopic hitting a node which didn't have its metadata updated yet. This patch fixes that by leveraging the KafkaTestUtils#describeTopic helper function which retries to guard against this
名称 | 最后提交 | 最后更新 |
---|