@Test
public void failure() {

    final StreamAck ack = StreamAck.failure(KNOWN_ELEMENT_ID);
    assertThat(ack.getElementId()).isEqualTo(KNOWN_ELEMENT_ID);
    assertThat(ack.getStatus()).isEqualTo(StreamAck.Status.FAILURE);
}