tree 41e483c3f113fc5ef4c3bd8698fe4da6914c06f5
parent 9d5c2c44e6b8bcc608c4042cef382a8ceb706cf4
author Yixing Zhang <tommykuaidlaa@gmail.com> 1601591204 -0700
committer GitHub <noreply@github.com> 1601591204 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJfdlekCRBK7hj4Ov3rIwAAdHIIADdvz7lQumI+3mpLfXoNXqF+
 am2nMh/+n6oKcbyg3++PVq5eFDK3ckZjZ0hRMB6oSfg3KgLAy/n02vebqZ+Wfkwv
 3j8j8zLwd6oZFsjB+IJE3GTqwknPpXvNR5a8mOXNbjNyhbDpq8sQnXDG4Q2mzZBZ
 VF7mG1ITRrpv3Ks+KBIuhDSTp0gj9w9fXQ6VWnoJcOjCB3kV8JI4KDhO1PxzeT7T
 kS8Tlglmswc7pLGLaboFgONbq0od/aiPrJBTpWNqaDKnazPgIXmED3NRsfL2dZGF
 3UTf6zXEz0jaeFW7Y29tTeQvPnqW04clPk8ZWswgnVp1zsSsLNSscDZx70AGUdM=
 =FQEt
 -----END PGP SIGNATURE-----
 

SAMZA-2587: IntermediateMessageSerde exception handling (#1426)

Upgrade Instructions: For users that are upgrading directly from samza version 0.13.0 or older versions: A message type of intermediate messages was introduced in samza 0.13.1. For samza 0.13.0 or older versions, the first byte of MessageType doesn't exist in the bytes. Thus, upgrading from those versions will fail. There are three ways to fix this issue:
a) Reset checkpoint to consume from newest message in the intermediate stream
b) Clean all existing messages in the intermediate stream
c) Run the application in any version between 0.13.1 and 1.5 until all old messages in intermediate stream has reached retention time.

Co-authored-by: Yixing Zhang <yixzhang@linkedin.com>