Sample of structure for Batcher

Batcher.java

public class Batcher {
    
    static class Flusher implements Runnable {
        private ConcurrentLinkedQueue<Events.Event> queu = new ConcurrentLinkedQueue<>();

        @Override
        public void run() {
            // Flush with defined interval or with special rules
        }
        
        public void addEvent(Events.Event event) {
            queu.add(event);
        }
    }
    
    public static Events.Event enrichAndConvert(Map<String, Object> events) {
        // Convert event and do what you want
        return null;
    }
    
    public static void main(String[] args) {
        List<Map<String, Object>> events = ImmutableList.of();

        Flusher flusher = new Flusher();
        ForkJoinPool.commonPool().execute(flusher);
        
        for (Map<String, Object> event : events) {
            ForkJoinPool.commonPool().execute(() -> {
                flusher.addEvent(enrichAndConvert(event));
            });
        }
    }
}