Ack failures too

snowplow · May 31, 2024 · 07253e2 · 07253e2
1 parent 93e84fe
commit 07253e2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/target/http.go b/pkg/target/http.go
@@ -286,7 +286,10 @@ func (ht *HTTPTarget) Write(messages []*models.Message) (*models.TargetWriteResu
 			}
 		} else {
 			errResult = multierror.Append(errResult, errors.New("Got response status: "+resp.Status))
-			// This stops retries for this demo.
+			// For the demo, ack failures too, because it's confusing when they re-appear.
+			if msg.AckFunc != nil {
+				msg.AckFunc()
+			}
 			failed = append(failed, msg)
 			continue
 		}