Skip to content
代码片段 群组 项目
提交 ef49076b 编辑于 作者: Greg Harris's avatar Greg Harris 提交者: Randall Hauch
浏览文件

KAFKA-10295: Wait for connector recovery in test_bounce (#9043)


Signed-off-by: default avatarGreg Harris <gregh@confluent.io>
上级 f93056ea
No related branches found
No related tags found
无相关合并请求
......@@ -387,8 +387,22 @@ class ConnectDistributedTest(Test):
# through the test.
time.sleep(15)
# Wait at least scheduled.rebalance.max.delay.ms to expire and rebalance
time.sleep(60)
# Allow the connectors to startup, recover, and exit cleanly before
# ending the test. It's possible for the source connector to make
# uncommitted progress, and for the sink connector to read messages that
# have not been committed yet, and fail a later assertion.
wait_until(lambda: self.is_running(self.source), timeout_sec=30,
err_msg="Failed to see connector transition to the RUNNING state")
time.sleep(15)
self.source.stop()
# Ensure that the sink connector has an opportunity to read all
# committed messages from the source connector.
wait_until(lambda: self.is_running(self.sink), timeout_sec=30,
err_msg="Failed to see connector transition to the RUNNING state")
time.sleep(15)
self.sink.stop()
self.cc.stop()
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册