You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2020/10/30 10:39:04 UTC
[kafka] branch trunk updated: MINOR: Add missing DESCRIBE_QUORUM
ApiKey in AbstractRequest.parseRequest (#9537)
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 <av...@confluent.io>
AuthorDate: Fri Oct 30 03:37:44 2020 -0700
MINOR: Add missing DESCRIBE_QUORUM ApiKey in AbstractRequest.parseRequest (#9537)
Reviewers: David Jacot <dj...@confluent.io>
---
.../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: