@Test
public void getMessageIdFromSource() {

    MyTask myTask = new MyTask();
    String offset = "12345";
    SystemStreamPartition ssp = new SystemStreamPartition("fakeSystem", "fakeStream", new Partition(56789));
    IncomingMessageEnvelope envelope = new IncomingMessageEnvelope(ssp, offset, null, null);
    assertEquals("fakeStream-56789-12345", myTask.getMessageIdFromSource(envelope));
}