aashish-confluent opened a new pull request, #23998: URL: https://github.com/apache/kafka/pull/23998
Check the record length in SubscriptionWrapperSerde.deserialize against the fixed header (version and instruction bytes, the optional 16-byte hash and the 4-byte primary partition for version 1) before reading it, and reject unknown versions before parsing. A truncated record now throws a SerializationException instead of a NegativeArraySizeException or BufferUnderflowException. Added unit tests in SubscriptionWrapperSerdeTest. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
