Skip to content

Commit 7531149

Browse files
authored
Merge pull request #1161 from kaleido-io/backport
Allow receiving a message with no data
2 parents 43de890 + 29bd4ff commit 7531149

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/events/persist_batch.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@ func (em *eventManager) persistBatch(ctx context.Context, batch *core.Batch) (pe
4040
return nil, false, nil // This is not retryable. skip this batch
4141
}
4242

43-
if len(batch.Payload.Messages) == 0 || len(batch.Payload.Data) == 0 {
44-
l.Errorf("Invalid batch '%s'. Missing messages (%d) or data (%d)", batch.ID, len(batch.Payload.Messages), len(batch.Payload.Data))
43+
if len(batch.Payload.Messages) == 0 {
44+
l.Errorf("Invalid batch '%s'. No messages in batch.", batch.ID)
4545
return nil, false, nil // This is not retryable. skip this batch
4646
}
4747

0 commit comments

Comments
 (0)