You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2026/06/15 14:52:06 UTC
[PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka]
dongnuo123 opened a new pull request, #22580:
URL: https://github.com/apache/kafka/pull/22580
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.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka]
Posted by "dajac (via GitHub)" <gi...@apache.org>.
dajac commented on PR #22580:
URL: https://github.com/apache/kafka/pull/22580#issuecomment-4776592209
Merged to trunk. The cherry-pick to 4.3 is not clear. @dongnuo123 Could you please raise a PR for it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20662: Throw `INCONSISTENT_GROUP_PROTOCOL` for malformed request during online migration [kafka]
Posted by "dajac (via GitHub)" <gi...@apache.org>.
dajac merged PR #22580:
URL: https://github.com/apache/kafka/pull/22580
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org