Skip to content
代码片段 群组 项目
提交 786b885d 编辑于 作者: Rajini Sivaram's avatar Rajini Sivaram
浏览文件

KAFKA-10404; Use higher poll timeout to avoid rebalance in testCoordinatorFailover (#9183)

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
上级 817f7915
无相关合并请求
......@@ -52,7 +52,9 @@ abstract class BaseConsumerTest extends AbstractConsumerTest {
def testCoordinatorFailover(): Unit = {
val listener = new TestConsumerReassignmentListener()
this.consumerConfig.setProperty(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "5001")
this.consumerConfig.setProperty(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, "2000")
this.consumerConfig.setProperty(ConsumerConfig.HEARTBEAT_INTERVAL_MS_CONFIG, "1000")
// Use higher poll timeout to avoid consumer leaving the group due to timeout
this.consumerConfig.setProperty(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, "15000")
val consumer = createConsumer()
consumer.subscribe(List(topic).asJava, listener)
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册