From: Yuri Weinstein <yweinste@redhat.com>
Date: Wed, 29 Jan 2025 23:23:20 +0000 (-0800)
Subject: Merge pull request #56158 from yuvalif/wip-64885-reef
X-Git-Tag: v18.2.5~134
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=239c518303ebc72c2f61e97c89b9c250e6457a15;p=ceph.git

Merge pull request #56158 from yuvalif/wip-64885-reef

reef: rgw/kafka: set message timeout to 5 seconds

Reviewed-by: J. Eric Ivancich <ivancich@redhat.com>
---

239c518303ebc72c2f61e97c89b9c250e6457a15
diff --cc src/rgw/rgw_kafka.cc
index b85b8344efd0c,03b11980ae7c2..290fde360ff0d
--- a/src/rgw/rgw_kafka.cc
+++ b/src/rgw/rgw_kafka.cc
@@@ -458,10 -465,10 +464,10 @@@ private
          auto& conn = conn_it->second;
  
          // Checking the connection idlesness
-         if(conn->timestamp.sec() + max_idle_time < ceph_clock_now()) {
+         if(conn->timestamp.sec() + conn->cct->_conf->rgw_kafka_connection_idle < ceph_clock_now()) {
            ldout(conn->cct, 20) << "kafka run: deleting a connection due to idle behaviour: " << ceph_clock_now() << dendl;
            std::lock_guard lock(connections_lock);
 -          conn->destroy(STATUS_CONNECTION_IDLE);
 +          conn->status = STATUS_CONNECTION_IDLE;
            conn_it = connections.erase(conn_it);
            --connection_count; \
            continue;