Skip to content

Commit d13f134

Browse files
committed
Cleanup
1 parent b0c255d commit d13f134

1 file changed

Lines changed: 0 additions & 2 deletions

File tree

pkg/source/kinesis/kinesis_source_test.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -276,11 +276,9 @@ func TestKinesisSource_KinsumerMetrics(t *testing.T) {
276276
foundNonZeroRecords := false
277277
foundNonZeroBytes := false
278278
for _, buffer := range capturedBuffers {
279-
fmt.Println("KinsumerRecordsInMemory:", buffer.KinsumerRecordsInMemory)
280279
if buffer.KinsumerRecordsInMemory > 0 {
281280
foundNonZeroRecords = true
282281
}
283-
fmt.Println("KinsumerRecordsInMemoryBytes:", buffer.KinsumerRecordsInMemoryBytes)
284282
if buffer.KinsumerRecordsInMemoryBytes > 0 {
285283
foundNonZeroBytes = true
286284
}

0 commit comments

Comments
 (0)