From 4f54cc0192004f2adff08a7e604fd754e19f0116 Mon Sep 17 00:00:00 2001
From: Justin Leong <justinleong16@gmail.com>
Date: Thu, 22 Aug 2024 16:18:54 -0700
Subject: [PATCH] fix: Use nondurable cursors for pulsar readers

---
 src/consumer/builder.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/consumer/builder.rs b/src/consumer/builder.rs
index 1f206ed6..d356f760 100644
--- a/src/consumer/builder.rs
+++ b/src/consumer/builder.rs
@@ -324,6 +324,9 @@ impl<Exe: Executor> ConsumerBuilder<Exe> {
         // would this clone() consume too much memory?
         let (mut config, mut joined_topics) = self.clone().validate::<T>().await?;
 
+        // Internally, the reader interface is implemented as a consumer using an exclusive, non-durable subscription
+        config.options.durable(false);
+
         // the validate() function defaults sub_type to SubType::Shared,
         // but a reader's subscription is exclusive
         warn!("Subscription Type for a reader is `Exclusive`. Resetting.");