Brief Summary
As a suggestion, I think for those who need to control the commit manually when using
@ActivationConfigProperty(propertyName = "EnableAutoCommit", propertyValue = "false"),
We need to have a way to commit manually the messages, or a way to expose the consumer to do such thing.
Expected Outcome
@onrecord
public void consume(ConsumerRecord record) {
//process record
// a functionality here to commit the record on topic
}
}functionalitythe
Current Outcome
There is no option to commit manually, I have checked.to commit manually
Context
No response
Ecosystem Tool
Cloud Connectors
Brief Summary
As a suggestion, I think for those who need to control the commit manually when using
@ActivationConfigProperty(propertyName = "EnableAutoCommit", propertyValue = "false"),We need to have a way to commit manually the messages, or a way to expose the consumer to do such thing.
Expected Outcome
@onrecord
public void consume(ConsumerRecord record) {
//process record
// a functionality here to commit the record on topic
}
}functionalitythe
Current Outcome
There is no option to commit manually, I have checked.to commit manually
Context
No response
Ecosystem Tool
Cloud Connectors