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 <ivancich@redhat.com>

diff --cc src/test/rgw/bucket_notification/test_bn.py
index af126f8ae50206893f74fa04d01dd587bb9340b0,710960e4b80451248aa684ad77ee2079b05a1508..c09b6e247cd56762204afcb60f16fc058410e78c
--- 1/src/test/rgw/bucket_notification/test_bn.py
--- 2/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: