Daniel Chen created SAMZA-2658:
-----------------------------------
Summary: Remove kafka checkpoint key validation for forwards
compatibility
Key: SAMZA-2658
URL: https://issues.apache.org/jira/browse/SAMZA-2658
Project: Samza
Issue Type: Improvement
Reporter: Daniel Chen
Assignee: Daniel Chen
Currently KafkaChangelogKeySerde only deserializes checkpoints with the correct
key.
The key value should be validated in KafkaCheckpointManager instead where it
will skip all keys that are unknown.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
