From 7788031583a7feaec5c12ab6f556b5284cfc4d00 Mon Sep 17 00:00:00 2001 From: Ismael Juma Date: Tue, 28 Jan 2020 06:49:59 -0800 Subject: [PATCH] MINOR: Introduce 2.5-IV0 IBP As the feature freeze approaches, we should support `2.5` as the inter.broker.protocol.version value. There are no new APIs so far, so `2.5` is effectively equivalent to `2.4`. --- core/src/main/scala/kafka/api/ApiVersion.scala | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/api/ApiVersion.scala b/core/src/main/scala/kafka/api/ApiVersion.scala index 90ffb10347d8a..a2ec7a82e2fd7 100644 --- a/core/src/main/scala/kafka/api/ApiVersion.scala +++ b/core/src/main/scala/kafka/api/ApiVersion.scala @@ -94,7 +94,9 @@ object ApiVersion { // Add adding_replicas and removing_replicas fields to LeaderAndIsrRequest KAFKA_2_4_IV0, // Flexible version support in inter-broker APIs - KAFKA_2_4_IV1 + KAFKA_2_4_IV1, + // No new APIs, equivalent to 2.4-IV1 + KAFKA_2_5_IV0 ) // Map keys are the union of the short and full versions @@ -334,6 +336,13 @@ case object KAFKA_2_4_IV1 extends DefaultApiVersion { val id: Int = 25 } +case object KAFKA_2_5_IV0 extends DefaultApiVersion { + val shortVersion: String = "2.5" + val subVersion = "IV0" + val recordVersion = RecordVersion.V2 + val id: Int = 26 +} + object ApiVersionValidator extends Validator { override def ensureValid(name: String, value: Any): Unit = {