diff --git a/src/consumer/builder.rs b/src/consumer/builder.rs index 1f206ed..3f9607d 100644 --- a/src/consumer/builder.rs +++ b/src/consumer/builder.rs @@ -324,6 +324,10 @@ impl ConsumerBuilder { // would this clone() consume too much memory? let (mut config, mut joined_topics) = self.clone().validate::().await?; + // Internally, the reader interface is implemented as a consumer using an exclusive, + // non-durable subscription + config.options.durable = Some(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.");