fix consumer issue

superstreamlabs · Aug 9, 2023 · 446d802 · 446d802
1 parent 6395c24
commit 446d802
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/src/Memphis.Client/Consumer/MemphisConsumer.cs b/src/Memphis.Client/Consumer/MemphisConsumer.cs
@@ -94,8 +94,6 @@ private void InitSubscription()
  if (Partitions.Length == 0)
  {
  var options = new ConsumerConfiguration.ConsumerConfigurationBuilder()
- .WithMaxExpires(_consumerOptions.BatchMaxTimeToWaitMs)
- .WithMaxDeliver(_consumerOptions.MaxMsgDeliveries)
  .WithDurable(internalSubjectName)
  .BuildPullSubscribeOptions();
 
@@ -109,8 +107,6 @@ private void InitSubscription()
  {
  var streamName = $"{internalSubjectName}${Partitions[i]}.final";
  var options = new ConsumerConfiguration.ConsumerConfigurationBuilder()
- .WithMaxExpires(_consumerOptions.BatchMaxTimeToWaitMs)
- .WithMaxDeliver(_consumerOptions.MaxMsgDeliveries)
  .WithDurable(internalSubjectName)
  .BuildPullSubscribeOptions();