diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java b/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java index 70456e7b024..9c1fdcfdcb7 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java @@ -35,6 +35,7 @@ import java.util.Map; * - {@link Errors#INVALID_REQUEST} * - {@link Errors#INVALID_GROUP_ID} * - {@link Errors#GROUP_ID_NOT_FOUND} + * - {@link Errors#TOPIC_AUTHORIZATION_FAILED} */ public class ConsumerGroupDescribeResponse extends AbstractResponse { diff --git a/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java b/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java index 76f89ed4df8..2d8b91c3d24 100644 --- a/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java +++ b/clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java @@ -39,6 +39,7 @@ import java.util.Map; * - {@link Errors#UNRELEASED_INSTANCE_ID} * - {@link Errors#GROUP_MAX_SIZE_REACHED} * - {@link Errors#INVALID_REGULAR_EXPRESSION} + * - {@link Errors#TOPIC_AUTHORIZATION_FAILED} */ public class ConsumerGroupHeartbeatResponse extends AbstractResponse { private final ConsumerGroupHeartbeatResponseData data; diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManagerTest.java b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManagerTest.java index dc6beea586b..c4a59a0221c 100644 --- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManagerTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManagerTest.java @@ -1029,7 +1029,8 @@ public class ConsumerHeartbeatRequestManagerTest { Arguments.of(Errors.UNSUPPORTED_VERSION, true), Arguments.of(Errors.UNRELEASED_INSTANCE_ID, true), Arguments.of(Errors.FENCED_INSTANCE_ID, true), - Arguments.of(Errors.GROUP_MAX_SIZE_REACHED, true)); + Arguments.of(Errors.GROUP_MAX_SIZE_REACHED, true), + Arguments.of(Errors.TOPIC_AUTHORIZATION_FAILED, false)); } private ClientResponse createHeartbeatResponse(NetworkClientDelegate.UnsentRequest request,