search

nomisRev / kotlin-kafka

Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.
https://nomisRev.github.io/kotlin-kafka/
Apache License 2.0
106 stars 10 forks source link

Add commitBatchWithin #51

Closed nomisRev closed 2 years ago

nomisRev commented 2 years ago

This PR introduces a new operator for time-and-size spaced chunking, and uses it to implement an operator to commit Kafka records in batches. Still allows you to optimise committing offsets as suggested in their official documentation.

Inspired by FS2-kafka from Scala eco-system.