This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 328c58f MINOR: Add missing DESCRIBE_QUORUM ApiKey in
AbstractRequest.parseRequest (#9537)
328c58f is described below
commit 328c58f94ab2231b3842f8cc587200db498e2580
Author: Anastasia Vela <[email protected]>
AuthorDate: Fri Oct 30 03:37:44 2020 -0700
MINOR: Add missing DESCRIBE_QUORUM ApiKey in AbstractRequest.parseRequest
(#9537)
Reviewers: David Jacot <[email protected]>
---
.../src/main/java/org/apache/kafka/common/requests/AbstractRequest.java | 2 ++
1 file changed, 2 insertions(+)
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 e96f748..9d8f346 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
@@ -255,6 +255,8 @@ public abstract class AbstractRequest implements
AbstractRequestResponse {
return new BeginQuorumEpochRequest(struct, apiVersion);
case END_QUORUM_EPOCH:
return new EndQuorumEpochRequest(struct, apiVersion);
+ case DESCRIBE_QUORUM:
+ return new DescribeQuorumRequest(struct, apiVersion);
case ALTER_ISR:
return new AlterIsrRequest(new AlterIsrRequestData(struct,
apiVersion), apiVersion);
case UPDATE_FEATURES:
