@Test
public void spoutShouldBeKafkaFileReadSpout() {

  KafkaProducer producer = new FileReadKafkaProducer();
  producer.getTopology(new Config());
  assertThat(producer.getSpout()).isInstanceOf(FileReadSpout.class);
}