]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commit
rgw/kafka: do not destroy the connection on errors 57784/head
authorYuval Lifshitz <ylifshit@ibm.com>
Thu, 7 Mar 2024 11:49:10 +0000 (11:49 +0000)
committerYuval Lifshitz <ylifshit@ibm.com>
Thu, 30 May 2024 14:34:22 +0000 (14:34 +0000)
commit7ad2595782c64f3912b25ef3ea41299f57365ccc
tree12a00ca7514527aef8895958b0e9c4ac2c50d592
parent3d89accfe3201286f000e065a1faea2a88c7a6ba
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>
(cherry picked from commit 1b6e8501565972bc833118a3fe34ef2f43f400ad)

 Conflicts:
src/rgw/rgw_kafka.cc
src/rgw/rgw_kafka.cc