From 9d932f62d85e232bd02d82da8b9b3562aa7a432d Mon Sep 17 00:00:00 2001 From: Ismael Juma Date: Thu, 6 Apr 2017 23:18:12 +0100 Subject: [PATCH] HOTFIX: Remove duplicate entry from ApiVersion --- .../common/requests/OffsetsForLeaderEpochRequest.java | 8 ++++---- core/src/main/scala/kafka/api/ApiVersion.scala | 5 ++--- 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java index fed891073fc5c..38fabf0990399 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java @@ -145,9 +145,9 @@ public AbstractResponse getErrorResponse(Throwable e) { return new OffsetsForLeaderEpochResponse(errorResponse); } - private class PartitionLeaderEpoch { - int partitionId; - int epoch; + private static class PartitionLeaderEpoch { + final int partitionId; + final int epoch; public PartitionLeaderEpoch(int partitionId, int epoch) { this.partitionId = partitionId; @@ -172,4 +172,4 @@ public int hashCode() { return result; } } -} \ No newline at end of file +} diff --git a/core/src/main/scala/kafka/api/ApiVersion.scala b/core/src/main/scala/kafka/api/ApiVersion.scala index 051c5d6728217..62d5d1261ccb3 100644 --- a/core/src/main/scala/kafka/api/ApiVersion.scala +++ b/core/src/main/scala/kafka/api/ApiVersion.scala @@ -67,8 +67,7 @@ object ApiVersion { "0.11.0-IV0" -> KAFKA_0_11_0_IV0, // introduced DeleteRecordsRequest v0 and FetchRequest v4 in KIP-107 "0.11.0-IV1" -> KAFKA_0_11_0_IV1, - "0.11.0" -> KAFKA_0_11_0_IV1, - // Introduce leader epoch fetches to the replica fetcher via KIP-101 + // Introduced leader epoch fetches to the replica fetcher via KIP-101 "0.11.0-IV2" -> KAFKA_0_11_0_IV2, "0.11.0" -> KAFKA_0_11_0_IV2 ) @@ -171,4 +170,4 @@ case object KAFKA_0_11_0_IV2 extends ApiVersion { val version: String = "0.11.0-IV2" val messageFormatVersion: Byte = RecordBatch.MAGIC_VALUE_V2 val id: Int = 12 -} \ No newline at end of file +}