summaryrefslogtreecommitdiffstats
path: root/src/rgw/rgw_kafka.cc (follow)
Commit message (Expand)AuthorAgeFilesLines
* rgw: allow bucket notification send message to kafka with multiple brokersHoai-Thu Vuong2024-12-261-7/+16
* common: cache pthread namesPatrick Donnelly2024-10-251-6/+1
* rgw/kafka: refactor topic creation to avoid rd_kafka_topic_name()Yuval Lifshitz2024-09-111-14/+15
* Merge pull request #57537 from kchheda3/wip_fix_notification_cachingCasey Bodley2024-07-021-50/+111
|\
| * rgw/notification: For kafka include user-id & password as part of the key alo...kchheda32024-05-281-50/+111
* | rgw: do not assert on thread name setting failuresYuval Lifshitz2024-06-131-2/+5
|/
* rgw/kafka: do not destroy the connection on errorsYuval Lifshitz2024-05-221-150/+146
* rgw/notifications: start/stop endpoint managers in notification managerYuval Lifshitz2024-05-121-1/+13
* rgw/s3-notifications: added user-name/password topic attributes for use with ...igomon2024-04-161-3/+22
* Merge pull request #56008 from kchheda3/wip-notification-subsysCasey Bodley2024-03-211-1/+1
|\
| * rgw/notification: add rgw notification specific debug log subsystem.kchheda32024-03-191-1/+1
* | rgw/kafka: set message timeout to 5 secondsYuval Lifshitz2024-03-071-1/+8
|/
* rgw/kafka: make the connection idle and sleep timeouts and configurableYuval Lifshitz2024-01-011-11/+7
* Merge pull request #54215 from kchheda3/wip-fix-kafka-breakYuval Lifshitz2023-12-061-3/+7
|\
| * rgw/notification: Fix Kafka persistent notification breakage that are not re...kchheda32023-10-301-3/+7
* | rgw: fix spelling errorsJosh Soref2023-11-271-6/+6
|/
* rgw/kafka: fix potential memory leak when push to queue failsYuval Lifshitz2023-06-201-2/+6
* rgw: user correct tags for coverity annotations and add the SUPPRESSVedansh Bhartia2023-06-141-1/+1
* Merge pull request #51972 from vedanshbhartia/coverity_resource_leakYuval Lifshitz2023-06-121-0/+1
|\
| * rgw: Add coverity annotations for resource leak false positivesVedansh Bhartia2023-06-071-0/+1
* | rgw/kafka: make sure that destroy is called after connection is removedYuval Lifshitz2023-06-011-2/+3
* | Merge pull request #51662 from yuvalif/wip-yuval-61328Yuval Lifshitz2023-05-281-89/+62
|\ \
| * | rgw/notification/kafka: simplify kafka connection memory managementYuval Lifshitz2023-05-221-89/+62
| |/
* / rgw/kafka: remove potential race condition between creation and deletion of e...Yuval Lifshitz2023-05-181-0/+1
|/
* rgw/kafka: failed to reconnect to broker after idle timeoutYuval Lifshitz2023-04-091-14/+23
* src/rgw: SASL_PLAINTEXT implementationHuy Nguyen2023-02-141-1/+15
* src/rgw: SASL mechanism implementationhuynp19992023-02-141-9/+22
* rgw/kafka: route librdkafka log messages to rgw logYuval Lifshitz2022-11-151-0/+28
* src/rgw: Connection timeout implementationKalpesh Pandya2021-09-011-0/+11
* src/rgw: Deletion of marked_for_deletion parameterKalpesh Pandya2021-08-261-31/+2
* rgw: Make some thread entry-points noexceptAdam C. Emerson2021-01-111-1/+1
* rgw/kafka: fix potential crash when accessing tagsYuval Lifshitz2020-10-061-1/+2
* rgw/pubsub: add ssl+sasl security to kafkaYuval Lifshitz2020-01-081-62/+104
* rgw/pubsub: prevent kafka thread from spinning when there are noYuval Lifshitz2019-12-031-5/+5
* rgw/pubsub: add kafka notification endpointYuval Lifshitz2019-11-051-0/+677
generated by cgit v1.2.3 (git 2.39.1) at 2025-01-18 13:14:22 +0100