Skip to content

Commit

Permalink
Merge pull request #568 from jeantil/expose-consumer-subscription-mode
Browse files Browse the repository at this point in the history
Exposes subscription mode for consumer
  • Loading branch information
judu authored Feb 7, 2024
2 parents a84a813 + 886be5c commit 1d25807
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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) }
Expand Down

0 comments on commit 1d25807

Please sign in to comment.