Fixed MassTransit#4345 - discard skipped/faulted messages for Kafka/E…

…vent Hub
RJSonnenberg · May 22, 2023 · e078cd5 · e078cd5
1 parent 576a292
commit e078cd5
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/...ntHubIntegration/EventHubIntegration/Configuration/EventHubReceiveEndpointConfigurator.cs b/...ntHubIntegration/EventHubIntegration/Configuration/EventHubReceiveEndpointConfigurator.cs
@@ -55,6 +55,9 @@ public EventHubReceiveEndpointConfigurator(IEventHubHostConfiguration hostConfig
             _blobClient = new Lazy<BlobContainerClient>(CreateBlobClient);
 
             PublishFaults = false;
+
+            this.DiscardFaultedMessages();
+            this.DiscardSkippedMessages();
         }
 
         public override Uri HostAddress => _endpointConfiguration.HostAddress;

diff --git a/...KafkaIntegration/KafkaIntegration/Configuration/KafkaTopicReceiveEndpointConfiguration.cs b/...KafkaIntegration/KafkaIntegration/Configuration/KafkaTopicReceiveEndpointConfiguration.cs
@@ -55,6 +55,9 @@ public KafkaTopicReceiveEndpointConfiguration(IKafkaHostConfiguration hostConfig
             _consumerConfigurator = new PipeConfigurator<ConsumerContext>();
 
             PublishFaults = false;
+
+            this.DiscardFaultedMessages();
+            this.DiscardSkippedMessages();
         }
 
         public override Uri HostAddress => _endpointConfiguration.HostAddress;