]> git.apps.os.sepia.ceph.com Git - ceph.git/commit
projects / ceph.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: a052683) | patch
rgw/kafka: do not destroy the connection on errors 56033/head
authorYuval Lifshitz <ylifshit@ibm.com>
Thu, 7 Mar 2024 11:49:10 +0000 (11:49 +0000)
committerYuval Lifshitz <ylifshit@ibm.com>
Wed, 22 May 2024 18:29:45 +0000 (18:29 +0000)
commit1b6e8501565972bc833118a3fe34ef2f43f400ad
treebd3856de6cf7c8229fb83688449982acc0ec099etree | snapshot
parenta052683f71ff61d052b02cef9f59d85aecabdececommit | diff
rgw/kafka: do not destroy the connection on errors

as well as other simplifications:
* do not store temporary configuration in the connection object. just
  use as a local variable
* do not create a connection without a producer

other improvements:
* copy to a local list before publishing
* convert internal error codes to errno

Fixes: https://tracker.ceph.com/issues/66017
Signed-off-by: Yuval Lifshitz <ylifshit@ibm.com>
src/rgw/rgw_kafka.cc diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.