public static String getCheckpointTopic(String jobName, String jobId, Config config) {
    String checkpointTopic = String.format(CHECKPOINT_TOPIC_FORMAT, CHECKPOINT_LOG_VERSION_NUMBER,
        jobName.replaceAll("_", "-"), jobId.replaceAll("_", "-"));
    return StreamManager.createUniqueNameForBatch(checkpointTopic, config);
  }
Need to fill in checkpoint log version number, job name, job id.
samza-kafka/src/main/java/org/apache/samza/util/KafkaUtil.java