class SemanticLogger::Appender::Kafka

def flush

Restart producer thread since there is no other way to flush. 
def flush
  @producer.shutdown
  @producer = @kafka.async_producer(
    delivery_threshold: delivery_threshold,
    delivery_interval:  delivery_interval
  )
end