It would be good to make camel-kafka and camel-vertx-kafka consumer able to batch together N messages via aggregation strategy as a single outgoing exchange. The batch should support group size, and timeout.
Something that was in the sjms-batch component.
The batching should use the same KafkaConsumer instance and defer the commit till the batching has been done. This requires manual offset commit by the consumer.
The use-case has been discussed on the chat at