Flume event-based data ingestion