Skip to content

Commit 528d98c

Browse files
committed
fix: if handle return nil, commit message
1 parent d4595c3 commit 528d98c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

processor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -250,7 +250,7 @@ func (h *handler) handle(ctx context.Context) error {
250250
h.logger.Warn("action", "handle", "err", err)
251251
}
252252

253-
if !h.hasBatch {
253+
if !h.hasBatch || v == nil {
254254
if err := h.commit(*msg); err != nil {
255255
return err
256256
}

0 commit comments

Comments
 (0)