Skip to content

Commit

Permalink
fix(test): use reduced set of versions for matrix
Browse files Browse the repository at this point in the history
  • Loading branch information
dnwe committed Jul 22, 2022
1 parent 462fe81 commit d854c83
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 2 deletions.
4 changes: 2 additions & 2 deletions functional_consumer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -444,8 +444,8 @@ func versionRange(lower KafkaVersion) []KafkaVersion {
upper = MaxVersion
}

versions := make([]KafkaVersion, 0, len(SupportedVersions))
for _, v := range SupportedVersions {
versions := make([]KafkaVersion, 0, len(fvtRangeVersions))
for _, v := range fvtRangeVersions {
if !v.IsAtLeast(lower) {
continue
}
Expand Down
20 changes: 20 additions & 0 deletions utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -233,6 +233,26 @@ var (
MinVersion = V0_8_2_0
MaxVersion = V3_2_0_0
DefaultVersion = V1_0_0_0

// reduced set of versions to matrix test
fvtRangeVersions = []KafkaVersion{
V0_8_2_2,
V0_10_2_2,
V1_0_2_0,
V1_1_1_0,
V2_0_1_0,
V2_1_1_0,
V2_2_2_0,
V2_3_1_0,
V2_4_1_0,
V2_5_1_0,
V2_6_2_0,
V2_7_1_0,
V2_8_1_0,
V3_0_1_0,
V3_1_0_0,
V3_2_0_0,
}
)

// ParseKafkaVersion parses and returns kafka version or error from a string
Expand Down

0 comments on commit d854c83

Please sign in to comment.