diff --git a/consumer/api/python/asapo_consumer.pxd b/consumer/api/python/asapo_consumer.pxd
index 429996ac00a72a0e46be9a53860fe3d78c527b2e..1e0cd28fab02fccab33542053e44358035b29ba0 100644
--- a/consumer/api/python/asapo_consumer.pxd
+++ b/consumer/api/python/asapo_consumer.pxd
@@ -56,6 +56,7 @@ cdef extern from "asapo_consumer.h" namespace "asapo" nogil:
     cdef cppclass DataBroker:
         DataBroker() except +
         void SetTimeout(uint64_t timeout_ms)
+        void ForceNoRdma()
         NetworkConnectionType CurrentConnectionType()
         Error GetNext(FileInfo* info, string group_id,string substream, FileData* data)
         Error GetLast(FileInfo* info, string group_id,string substream, FileData* data)
diff --git a/consumer/api/python/asapo_consumer.pyx.in b/consumer/api/python/asapo_consumer.pyx.in
index b817b1431df1f8063692c0ff21df8b305c7bae96..5f20dbe3c62d8fa6f3a0a8fad079b688867462b1 100644
--- a/consumer/api/python/asapo_consumer.pyx.in
+++ b/consumer/api/python/asapo_consumer.pyx.in
@@ -161,6 +161,8 @@ cdef class PyDataBroker:
         return size
     def set_timeout(self,timeout):
         self.c_broker.SetTimeout(timeout)
+    def force_no_rdma(self):
+        self.c_broker.ForceNoRdma()
     def current_connection_type(self):
         cdef NetworkConnectionType connection_type = self.c_broker.CurrentConnectionType()
         cdef int cased = <int>connection_type