Skip to content

Commit

Permalink
usm: kafka: test: Reduce test size (#26853)
Browse files Browse the repository at this point in the history
  • Loading branch information
vitkyrka authored Jun 19, 2024
1 parent f88a7a0 commit 44d4770
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pkg/network/usm/kafka_monitor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1014,13 +1014,13 @@ func testKafkaFetchRaw(t *testing.T, tls bool, apiVersion int) {

partition := makeFetchResponseTopicPartition(batches...)
var partitions []kmsg.FetchResponseTopicPartition
for i := 0; i < 100; i++ {
for i := 0; i < 25; i++ {
partitions = append(partitions, partition)
}

return makeFetchResponse(apiVersion, makeFetchResponseTopic(topic, partitions...))
},
numFetchedRecords: 1 * 1 * 100,
numFetchedRecords: 1 * 1 * 25,
},
{
name: "many topics",
Expand Down

0 comments on commit 44d4770

Please sign in to comment.