I have a kafka question. How does the kafka output handle backpressure caused by network latency or network disconnect? Is there a method that tells osquery/kafka producer where it left off in the database so it knows where to pick back up and start producing events from? I ask because I am looking to replace logstash as my shipper and use osquery to output results directly to kafka.