class OutputKafka extends Output<LogFeederProps, InputFileMarker> {

  @Override
  public void init(LogFeederProps logFeederProps) throws Exception {
    this.logFeederProps = logFeederProps;
    Properties props = initProperties();

    producer = creteKafkaProducer(props);
    createKafkaRetryThread();
  }

}