exposes subscription mode for consumer

The default subscription mode is durable but some use cases benefit from a non durable mode which currently cannot be configured through pulsar4s
CleverCloud · Nov 29, 2023 · 886be5c · 886be5c
1 parent e16d5cc
commit 886be5c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/pulsar4s-core/src/main/scala/com/sksamuel/pulsar4s/ConsumerConfig.scala b/pulsar4s-core/src/main/scala/com/sksamuel/pulsar4s/ConsumerConfig.scala
@@ -22,6 +22,7 @@ case class ConsumerConfig(subscriptionName: Subscription,
                           subscriptionInitialPosition: Option[SubscriptionInitialPosition] = None,
                           subscriptionTopicsMode: Option[RegexSubscriptionMode] = None,
                           subscriptionType: Option[SubscriptionType] = None,
+                          subscriptionMode: Option[SubscriptionMode] = None,
                           readCompacted: Option[Boolean] = None,
                           ackTimeout: Option[FiniteDuration] = None,
                           ackTimeoutTickTime: Option[FiniteDuration] = None,

diff --git a/pulsar4s-core/src/main/scala/com/sksamuel/pulsar4s/PulsarClient.scala b/pulsar4s-core/src/main/scala/com/sksamuel/pulsar4s/PulsarClient.scala
@@ -282,6 +282,7 @@ class DefaultPulsarClient(client: org.apache.pulsar.client.api.PulsarClient) ext
     config.subscriptionInitialPosition.foreach(builder.subscriptionInitialPosition)
     config.subscriptionTopicsMode.foreach(builder.subscriptionTopicsMode)
     config.subscriptionType.foreach(builder.subscriptionType)
+    config.subscriptionMode.foreach(builder.subscriptionMode)
     config.topicPattern.map(_.pattern).foreach(builder.topicsPattern)
     config.ackTimeout.foreach { t => builder.ackTimeout(t._1, t._2) }
     config.ackTimeoutTickTime.foreach { tt => builder.ackTimeoutTickTime(tt._1, tt._2) }