diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java b/clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java index fd5065dbeaad3..c9cb10b352975 100644 --- a/clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java +++ b/clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java @@ -133,10 +133,9 @@ public enum ApiKeys { READ_SHARE_GROUP_STATE_SUMMARY(ApiMessageType.READ_SHARE_GROUP_STATE_SUMMARY, true), STREAMS_GROUP_HEARTBEAT(ApiMessageType.STREAMS_GROUP_HEARTBEAT), STREAMS_GROUP_DESCRIBE(ApiMessageType.STREAMS_GROUP_DESCRIBE), - DESCRIBE_SHARE_GROUP_OFFSETS(ApiMessageType.DESCRIBE_SHARE_GROUP_OFFSETS); + DESCRIBE_SHARE_GROUP_OFFSETS(ApiMessageType.DESCRIBE_SHARE_GROUP_OFFSETS), GET_REPLICA_LOG_INFO(ApiMessageType.GET_REPLICA_LOG_INFO); - private static final Map> APIS_BY_LISTENER = new EnumMap<>(ApiMessageType.ListenerType.class); diff --git a/clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java index cb406da7f262f..f6b91f0f08760 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java @@ -349,7 +349,7 @@ private static AbstractRequest doParseRequest(ApiKeys apiKey, short apiVersion, case DESCRIBE_SHARE_GROUP_OFFSETS: return DescribeShareGroupOffsetsRequest.parse(buffer, apiVersion); case GET_REPLICA_LOG_INFO: - return GetReplicaLogInfoRequest.parse(buffer, apiVersion); + return GetReplicaLogInfoRequest.parse(buffer, apiVersion); default: throw new AssertionError(String.format("ApiKey %s is not currently handled in `parseRequest`, the " + "code should be updated to do so.", apiKey)); diff --git a/clients/src/main/resources/common/message/GetReplicaLogInfoRequest.json b/clients/src/main/resources/common/message/GetReplicaLogInfoRequest.json index f8955ad2839eb..d912e693b8853 100644 --- a/clients/src/main/resources/common/message/GetReplicaLogInfoRequest.json +++ b/clients/src/main/resources/common/message/GetReplicaLogInfoRequest.json @@ -14,7 +14,7 @@ // limitations under the License. { - "apiKey":83, + "apiKey":91, "type": "request", "listeners": ["broker"], "name": "GetReplicaLogInfoRequest", diff --git a/clients/src/main/resources/common/message/GetReplicaLogInfoResponse.json b/clients/src/main/resources/common/message/GetReplicaLogInfoResponse.json index 6f8c602aa022a..012746d00289d 100644 --- a/clients/src/main/resources/common/message/GetReplicaLogInfoResponse.json +++ b/clients/src/main/resources/common/message/GetReplicaLogInfoResponse.json @@ -14,7 +14,7 @@ // limitations under the License. { - "apiKey":83, + "apiKey":91, "type": "response", "name": "GetReplicaLogInfoResponse", "validVersions": "0", diff --git a/core/src/main/scala/kafka/network/RequestConvertToJson.scala b/core/src/main/scala/kafka/network/RequestConvertToJson.scala deleted file mode 100644 index e69de29bb2d1d..0000000000000