相关疑难解决方法(0)

有没有办法用Kafka Stream手动提交？

通常使用KafkaConsumer,我做类似下面的事情:

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

我手动调用提交的地方.我没有看到类似的API KStream.