|
@@ -161,6 +161,7 @@ var (
|
|
|
V2_1_0_0 = newKafkaVersion(2, 1, 0, 0)
|
|
|
V2_2_0_0 = newKafkaVersion(2, 2, 0, 0)
|
|
|
V2_3_0_0 = newKafkaVersion(2, 3, 0, 0)
|
|
|
+ V2_4_0_0 = newKafkaVersion(2, 4, 0, 0)
|
|
|
|
|
|
SupportedVersions = []KafkaVersion{
|
|
|
V0_8_2_0,
|
|
@@ -185,9 +186,10 @@ var (
|
|
|
V2_1_0_0,
|
|
|
V2_2_0_0,
|
|
|
V2_3_0_0,
|
|
|
+ V2_4_0_0,
|
|
|
}
|
|
|
MinVersion = V0_8_2_0
|
|
|
- MaxVersion = V2_3_0_0
|
|
|
+ MaxVersion = V2_4_0_0
|
|
|
)
|
|
|
|
|
|
|