diff --git a/cmd/fermentord/loop.go b/cmd/fermentord/loop.go
index 4f1e625..96c2d25 100644
--- a/cmd/fermentord/loop.go
+++ b/cmd/fermentord/loop.go
@@ -107,7 +107,7 @@ func mainLoop(ctx context.Context, wg *sync.WaitGroup, js nats.JetStream, config
 			}
 
 			// Publish to NATS
-			_, err = js.Publish(config.NATS.Subject.Event, b)
+			_, err = js.Publish(config.NATS.Subject.Event, b, nats.AckWait(1*time.Second))
 			if err != nil {
 				hub.CaptureException(err)
 				log.Print(err)
diff --git a/internal/dwingest/nats.go b/internal/dwingest/nats.go
index b6cf851..5c126ac 100644
--- a/internal/dwingest/nats.go
+++ b/internal/dwingest/nats.go
@@ -92,7 +92,7 @@ func publish(subject string, js nats.JetStream, hub *sentry.Hub, reading any) er
 		return err
 	}
 
-	_, err = js.Publish(subject, b)
+	_, err = js.Publish(subject, b, nats.AckWait(1*time.Second))
 	if err != nil {
 		hub.CaptureException(err)
 		log.Print(err)