]> git.apps.os.sepia.ceph.com Git - ceph.git/commit
rgw: allow bucket notification send message to kafka with multiple brokers 60988/head
authorHoai-Thu Vuong <thuvh87@gmail.com>
Tue, 9 Jul 2024 16:56:51 +0000 (23:56 +0700)
committerHoai-Thu Vuong <thuvh87@gmail.com>
Thu, 26 Dec 2024 03:33:54 +0000 (10:33 +0700)
commit1a34cd1be9f2c10a8262372e0a5bab396655bdab
treef87ceb001c50069e9241c3874edba78f96e26de7
parent5061b31102daaa52b56749252e81aaccb8a3ab83
rgw: allow bucket notification send message to kafka with multiple brokers

- add new parameter to define list of broker
- update document
- change nose to nose-py3
- add test case for multiple brokers (happy case)

Signed-off-by: Hoai-Thu Vuong <thuvh87@gmail.com>
12 files changed:
doc/radosgw/notifications.rst
qa/suites/rgw/notifications/tasks/kafka_failover/+ [new file with mode: 0644]
qa/suites/rgw/notifications/tasks/kafka_failover/0-install.yaml [new file with mode: 0644]
qa/suites/rgw/notifications/tasks/kafka_failover/supported-distros [new symlink]
qa/suites/rgw/notifications/tasks/kafka_failover/test_kafka.yaml [new file with mode: 0644]
qa/tasks/kafka_failover.py [new file with mode: 0644]
qa/tasks/notification_tests.py
src/rgw/driver/rados/rgw_pubsub_push.cc
src/rgw/rgw_kafka.cc
src/rgw/rgw_kafka.h
src/test/rgw/bucket_notification/requirements.txt
src/test/rgw/bucket_notification/test_bn.py