private IncomingMessageEnvelope newCheckpointV1Envelope(TaskName taskName, CheckpointV1 checkpointV1,
      String checkpointMessageOffset) {
    KafkaCheckpointLogKey checkpointKey = new KafkaCheckpointLogKey("checkpoint", taskName, GROUPER_FACTORY_CLASS);
    KafkaCheckpointLogKeySerde checkpointKeySerde = new KafkaCheckpointLogKeySerde();
    CheckpointV1Serde checkpointMsgSerde = new CheckpointV1Serde();
    return new IncomingMessageEnvelope(CHECKPOINT_SSP, checkpointMessageOffset,
        checkpointKeySerde.toBytes(checkpointKey), checkpointMsgSerde.toBytes(checkpointV1));
  }
Creates a new checkpoint envelope for the provided task, ssp and offset
samza-kafka/src/test/java/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.java