Skip to content
代码片段 群组 项目
提交 06341cfb 编辑于 作者: showuon's avatar showuon 提交者: Konstantine Karantasis
浏览文件

KAFKA-9509: Increase timeout when consuming records to fix flaky test in MM2 (#8894)

A simple increase in the timeout of the consumer that verifies that records have been replicated seems to fix the integration tests in `MirrorConnectorsIntegrationTest` that have been failing more often recently. 

Reviewers: Ryanne Dolan <ryannedolan@gmail.com>, Sanjana Kaundinya <skaundinya@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>, Konstantine Karantasis <konstantine@confluent.io>
上级 1d07fb8c
No related branches found
No related tags found
无相关合并请求
......@@ -58,7 +58,7 @@ public class MirrorConnectorsIntegrationTest {
private static final int NUM_RECORDS_PRODUCED = 100; // to save trees
private static final int NUM_PARTITIONS = 10;
private static final int RECORD_TRANSFER_DURATION_MS = 10_000;
private static final int RECORD_TRANSFER_DURATION_MS = 20_000;
private static final int CHECKPOINT_DURATION_MS = 20_000;
private MirrorMakerConfig mm2Config;
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册