(kafka) branch trunk updated: MINOR : Add missing error code in ConsumerHeartbeatRequestManagerTest. (#19024)

[lianetm]

This is an automated email from the ASF dual-hosted git repository.

lianetm 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 fae2e539013 MINOR : Add missing error code in 
ConsumerHeartbeatRequestManagerTest. (#19024)
fae2e539013 is described below

commit fae2e539013e8930d1800d8d7f1cc610ab0075dd
Author: Shivsundar R <s...@confluent.io>
AuthorDate: Tue Feb 25 15:35:20 2025 -0500

    MINOR : Add missing error code in ConsumerHeartbeatRequestManagerTest. 
(#19024)
    
    Reviewers: Lianet Magrans <lmagr...@confluent.io>
---
 .../apache/kafka/common/requests/ConsumerGroupDescribeResponse.java    | 1 +
 .../apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java   | 1 +
 .../consumer/internals/ConsumerHeartbeatRequestManagerTest.java        | 3 ++-
 3 files changed, 4 insertions(+), 1 deletion(-)

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,