\n");
b.append("| ");
b.append("" + key.name + "");
@@ -246,10 +260,19 @@ public void visit(Type field) {
return hasBuffer.get();
}
- public static List brokerApis() {
- return Arrays.stream(values())
- .filter(api -> !api.isControllerOnlyApi)
+ public static EnumSet zkBrokerApis() {
+ return apisForListener(ApiMessageType.ListenerType.ZK_BROKER);
+ }
+
+ public static EnumSet apisForListener(ApiMessageType.ListenerType listener) {
+ return APIS_BY_LISTENER.get(listener);
+ }
+
+ private static EnumSet filterApisForListener(ApiMessageType.ListenerType listener) {
+ List controllerApis = Arrays.stream(ApiKeys.values())
+ .filter(apiKey -> apiKey.messageType.listeners().contains(listener))
.collect(Collectors.toList());
+ return EnumSet.copyOf(controllerApis);
}
}
diff --git a/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java b/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
index f31c613a8c51b..d455b26eb2d87 100644
--- a/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
+++ b/clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java
@@ -133,7 +133,7 @@ public static String toHtml() {
b.append("\n");
schemaToFieldTableHtml(ResponseHeaderData.SCHEMAS[i], b);
}
- for (ApiKeys key : ApiKeys.brokerApis()) {
+ for (ApiKeys key : ApiKeys.zkBrokerApis()) {
// Key
b.append(" |