root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR : Add missing error code in ConsumerHeartbeatRequestManagerTest. (#19024) 

Reviewers: Lianet Magrans <lmagrans@confluent.io>
This commit is contained in:
Shivsundar R 2025-02-25 15:35:20 -05:00 committed by GitHub
parent 8be216b24f
commit fae2e53901
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java
View File

@ -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 {

1
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java
View File

@ -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;

3
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManagerTest.java
View File

@ -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,