Existe uma maneira de confirmar manualmente com o Kafka Stream?

Geralmente, usando oKafkaConsumer, Faço algo como abaixo:

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(100);
    for (ConsumerRecord<String, String> record : records){
       // process records
    }
   consumer.commitAsync();
}

Para onde estou chamando commit manualmente. Não vejo uma API semelhante paraKStream.