在这种情况下，一种常见的方法是将所有记录放在一个队列中。并且有一个线程，它将在队列达到10或1000毫秒后获取这些记录，具体取决于先到的是什么。
消费者代码：

CountDownLatch countDownLatch = new CountDownLatch(10);
 countDownLatch.await(1000, TimeUnit.MILLISECONDS);
 int queueSize = queue.size();
 for(int i = 0; i < queueSize; ++i) {
     ... do your work here or put in a batch a do it right after loop
 }

生产商代码：

Record record = ...receive new record...
 queue.put(record);
 consumer.getCountDownLatch().countDown();

作为一个队列，我建议使用unbound-one，比如 LinkedTransferQueue ，因为您不想在达到10个任务时停止生产者，所以仍然需要使用kafka的结果。
另一个选择是React流。

听起来你应该使用kafka连接api。这是apachekafka的一部分，旨在支持您描述的流程。
这里有一个开发者指南。