Bulk handler

BulkHandler.java

public static class BulkHandler implements Handler, Runnable {
        
        private BlockingQueue<Record> queue = new LinkedBlockingQueue<>(1000);
        
        public BulkHandler() {
            new Thread(this).start();
        }

        @Override
        public Status process(Record record) {
            queue.offer(record);
            return Status.SUCCESS;
        }
        
        public void run()  {
            while (true) {
                if (queue.isEmpty()) {
                    Thread.sleep(100);
                    continue;
                }
                List<Record> records = new ArrayList<>();
                queue.drainTo(records, 100);
                process(records);
            }
        }
        
        public void process(List<Record> records) {
            try {
                // Handle bulk records 
            } catch (Exception e) {
                // Push it to retry or dlq
            }
        }
    }