@Test
public void testPojoType() {

    Event event = new Event();
    event.setId(1);
    event.setName("test");
    event.setPrice(56.7);
    event.setTimestamp(CURRENT);
    StreamSchema<Event> schema = new StreamSchema<>(TypeExtractor.createTypeInfo(Event.class),
            "id", "name", "price", "timestamp");
    StreamSerializer<Event> reader = new StreamSerializer<>(schema);
    Assert.assertArrayEquals(new Object[]{1, "test", 56.7, CURRENT}, reader.getRow(event));
}