From: Casey Bodley Date: Mon, 3 Mar 2025 17:07:56 +0000 (-0500) Subject: Merge pull request #61595 from yuvalif/wip-63630-reef X-Git-Tag: v18.2.5~40 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=941acaa71e001a651117ebf07944333f4693df5d;p=ceph.git Merge pull request #61595 from yuvalif/wip-63630-reef reef: rgw/test/kafka: let consumer read events from the beginning Reviewed-by: J. Eric Ivancich --- 941acaa71e001a651117ebf07944333f4693df5d diff --cc src/test/rgw/bucket_notification/test_bn.py index af126f8ae50,710960e4b80..c09b6e247cd --- a/src/test/rgw/bucket_notification/test_bn.py +++ b/src/test/rgw/bucket_notification/test_bn.py @@@ -1604,11 -1609,12 +1605,11 @@@ def test_ps_s3_notification_push_kafka_ time_diff = time.time() - start_time print('average time for deletion + kafka notification is: ' + str(time_diff*1000/number_of_objects) + ' milliseconds') - print('wait for 5sec for the messages...') - time.sleep(5) + print('wait for 10sec for the messages...') + time.sleep(10) receiver.verify_s3_events(keys, exact_match=True, deletions=True, etags=etags) except Exception as e: - print(e) - assert False + assert False, str(e) finally: # cleanup if s3_notification_conf is not None: