Dongnuo Lyu created KAFKA-20662:
-----------------------------------
Summary: 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
In https://issues.apache.org/jira/browse/KAFKA-20570 we realized that 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 need to figure out a more appropriate error code for such case
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
