@Test
public void testEncodeEventStream() throws IOException {

  byte[] foo = new byte[] {1, 2, 3};
  byte[] encodedByteArray = new EventMessageEncoder().encode(DECODED_MESSAGE);
  assertThat(encodedByteArray).isEqualTo(ENCODED_MESSAGE);
}