[
https://issues.apache.org/jira/browse/KAFKA-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-20662.
---------------------------------
Fix Version/s: 4.4.0
Resolution: Fixed
> Proper error code for malformed request during online migration
> ---------------------------------------------------------------
>
> Key: KAFKA-20662
> URL: https://issues.apache.org/jira/browse/KAFKA-20662
> Project: Kafka
> Issue Type: Bug
> Reporter: Dongnuo Lyu
> Assignee: Dongnuo Lyu
> Priority: Major
> Fix For: 4.4.0
>
>
> In https://issues.apache.org/jira/browse/KAFKA-20570 we realized that when
> the subscription deserialization fails, we throw an IllegalStateException
>
> {code:java}
> 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."); }
> }
> {code}
> which will be translated to UNKNOWN_SERVER_ERROR. This is a bit confusing to
> the client. We need to figure out a more appropriate error code for such case
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
