Browse Source

HOTFIX: Remove duplicate entry from ApiVersion

Author: Ismael Juma <ismael@juma.me.uk>

Reviewers: Jun Rao <junrao@gmail.com>

Closes #2818 from ijuma/fix-api-version
pull/2818/merge
Ismael Juma 8 years ago committed by Jun Rao
parent
commit
76a10e23f0
  1. 8
      clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java
  2. 5
      core/src/main/scala/kafka/api/ApiVersion.scala

8
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java

@ -145,9 +145,9 @@ public class OffsetsForLeaderEpochRequest extends AbstractRequest { @@ -145,9 +145,9 @@ public class OffsetsForLeaderEpochRequest extends AbstractRequest {
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 class OffsetsForLeaderEpochRequest extends AbstractRequest { @@ -172,4 +172,4 @@ public class OffsetsForLeaderEpochRequest extends AbstractRequest {
return result;
}
}
}
}

5
core/src/main/scala/kafka/api/ApiVersion.scala

@ -67,8 +67,7 @@ object ApiVersion { @@ -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 { @@ -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
}
}

Loading…
Cancel
Save