A lightweight utility for Node.js projects that accumulates items into fixed-size batches per key, preserving insertion order within each key. Streams items directly into their respective batches at runtime, eliminating the overhead of post-processing 1D arrays into chunks. It abstracts key-based batch management.
nodejs typescript kafka stream batch partition kafka-producer batch-processing streaming-data accumulator keyed partitioned partitioned-data delayed-processing batched-items grouped-items keyed-batch
-
Updated
Jun 3, 2025 - TypeScript