KafkaUtil { public static SystemStreamPartition toSystemStreamPartition(String systemName, TopicPartition topicPartition) { Partition partition = new Partition(topicPartition.partition()); return new SystemStreamPartition(systemName, topicPartition.topic(), partition); }  static String getCheckpointTopic(String jobName, String jobId, Config config); static Integer getIntegerPartitionKey(OutgoingMessageEnvelope envelope, List<PartitionInfo> partitions); static SystemStreamPartition toSystemStreamPartition(String systemName, TopicPartition topicPartition);  }
@Test public void testToSystemStreamPartition() { String system = "mySystem", stream = "myStream"; int partition = 3; TopicPartition topicPartition = new TopicPartition(stream, partition); assertEquals(new SystemStreamPartition(system, stream, new Partition(partition)), KafkaUtil.toSystemStreamPartition(system, topicPartition)); }