.

src/Microsoft.Azure.EventHubs.Processor/PartitionManager.cs

@@ -315,9 +315,8 @@ namespace Microsoft.Azure.EventHubs.Processor
                 // There already is a pump. Make sure the pump is working and replace the lease.
                 if (capturedPump.PumpStatus == PartitionPumpStatus.Errored || capturedPump.IsClosing)
                 {
-                    // The existing pump is bad. Remove it and create a new one.
+                    // The existing pump is bad. Remove it.
                     await RemovePumpAsync(partitionId, CloseReason.Shutdown).ConfigureAwait(false);
-                    await CreateNewPumpAsync(partitionId, lease).ConfigureAwait(false);
                 }
                 else
                 {