Skip to content

KAFKA-20662: Throw INCONSISTENT_GROUP_PROTOCOL for malformed request during online migration#22580

Open
dongnuo123 wants to merge 1 commit into
apache:trunkfrom
confluentinc:KAFKA-20662
Open

KAFKA-20662: Throw INCONSISTENT_GROUP_PROTOCOL for malformed request during online migration#22580
dongnuo123 wants to merge 1 commit into
apache:trunkfrom
confluentinc:KAFKA-20662

Conversation

@dongnuo123

@dongnuo123 dongnuo123 commented Jun 15, 2026

Copy link
Copy Markdown
Contributor

When the subscription deserialization fails, we throw an
IllegalStateException

private static ConsumerProtocolSubscription deserializeSubscription(
  JoinGroupRequestProtocolCollection protocols
) {
  try {
  return ConsumerProtocol.deserializeConsumerProtocolSubscription(
    ByteBuffer.wrap(protocols.iterator().next().metadata()));
  }
  catch (SchemaException e) {
  throw new IllegalStateException("Malformed embedded consumer protocol
in subscription deserialization.");
  }
}

which will be translated to UNKNOWN_SERVER_ERROR. This is a bit
confusing to the client. We throw a fatal INCONSISTENT_GROUP_PROTOCOL
here instead.

@github-actions github-actions Bot added triage PRs from the community group-coordinator small Small PRs labels Jun 15, 2026
@dajac dajac added ci-approved and removed triage PRs from the community labels Jun 15, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants