Add an assert

ThreeDotsLabs · Aug 28, 2024 · 42b2e56 · 42b2e56
1 parent 07c306d
commit 42b2e56
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/kafka/pubsub_test.go b/pkg/kafka/pubsub_test.go
@@ -254,6 +254,7 @@ func TestCtxValuesAfterRetry(t *testing.T) {
 	require.NoError(t, err)
 
 	receivedMessage, ok := readAfterRetries(messages, 1, time.Second)
+	assert.True(t, ok)
 
 	expectedPartitionsOffsets := map[int32]int64{}
 	partition, ok := kafka.MessagePartitionFromCtx(receivedMessage.Context())