Skip to content

Commit beaca53

Browse files
committed
test log message
1 parent e31a5d0 commit beaca53

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tests/integration/topic_partitions_balanced_test.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,13 +158,15 @@ auto_partitioning_stabilization_window=Interval('PT1S')
158158

159159
t.Log("Read first partition id:", firstPartitionID)
160160

161+
readFromFirstPartition := 1
161162
readFromFirstPartition:
162163
for {
163164
msg, err = scope.TopicReader().ReadMessage(scope.Ctx)
164165
scope.Require.NoError(err)
165166
messagesCounter.Add(-1)
167+
readFromFirstPartition++
166168
if msg.PartitionID() != firstPartitionID {
167-
t.Log("Read first partition id:", msg.PartitionID())
169+
t.Log("Read first partition id:", msg.PartitionID(), "read from first partition:", readFromFirstPartition)
168170
break readFromFirstPartition
169171
}
170172
}

0 commit comments

Comments
 (0)