]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commit
rgw/notification/kafka: simplify kafka connection memory management 51662/head
authorYuval Lifshitz <ylifshit@redhat.com>
Mon, 22 May 2023 09:38:14 +0000 (09:38 +0000)
committerYuval Lifshitz <ylifshit@redhat.com>
Mon, 22 May 2023 09:38:14 +0000 (09:38 +0000)
commitfbd287602742ecbe6a0d383ce9db1b6a65c348cb
treeb7b7f9e3b43d41e54a61b0597fa638e3bda4e739
parent4dbf84a34d8b120dd5c901bd681fc590fae806c8
rgw/notification/kafka: simplify kafka connection memory management

use a bare pointer and a unique_ptr instead of a shared pointer (boost::intrusive_ptr).
and use the broker name as the handle exposed outside of the kafka module.

Fixes: https://tracker.ceph.com/issues/61328
Signed-off-by: Yuval Lifshitz <ylifshit@redhat.com>
src/rgw/driver/rados/rgw_pubsub_push.cc
src/rgw/rgw_kafka.cc
src/rgw/rgw_kafka.h