consumeAndCommitRecords

inline fun <T : Any> KafkaRest.consumeAndCommitRecords(group: ConsumerGroup, consumerInstance: ConsumerInstance, topic: Topic, recordFormat: RecordFormat, recordConsumer: RecordConsumer<T>): Result<List<Unit?>?, Any>

Process Records on a Topic using the passed RecordConsumer, and either commits the Offset after processing each.