@Test
public void spoutShouldBeKafkaPageViewSpout() {

  KafkaProducer producer = new PageViewKafkaProducer();
  producer.getTopology(new Config());
  assertThat(producer.getSpout()).isInstanceOf(PageViewSpout.class);
}