Update internal/ack/once.go

Co-authored-by: Tyler Rockwood <rockwood@redpanda.com>

Author: mmatczuk

internal/ack/once.go

@@ -38,14 +38,11 @@ func NewOnce(ack func(ctx context.Context) error) *Once {
 // See Once for details.
 func (a *Once) Ack(ctx context.Context, err error) error {
 	a.once.Do(func() {
-		if err != nil {
-			a.errCh <- err
-		} else {
-			a.ackErr = a.ack(ctx)
-			if a.ackErr != nil {
-				a.errCh <- a.ackErr
-			}
+		if err == nil {
+			err = a.ack(ctx)
 		}
+		a.errCh <- err
+		a.ackErr = err
 		close(a.errCh)
 	})