private SystemStreamPartition deserializeSSPFromJson(String sspAsJson) {
    try {
      return sspMapper.readValue(sspAsJson, SystemStreamPartition.class);
    } catch (IOException e) {
      throw new SamzaException(String.format("Exception occurred when deserializing the partition: %s", sspAsJson), e);
    }
  }
Deserializes the {@param sspAsJson} in json format to {@link SystemStreamPartition}.
@param sspAsJson the serialized SystemStreamPartition in json format.
@return the deserialized SystemStreamPartition.
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java