[ https://issues.apache.org/jira/browse/KAFKA-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Randall Hauch resolved KAFKA-4598. ---------------------------------- Resolution: Implemented Marking as implemented via KAFKA-7500, via the `SourceTask.commitRecord(...)` methods. > Create new SourceTask commit callback method that takes offsets param > --------------------------------------------------------------------- > > Key: KAFKA-4598 > URL: https://issues.apache.org/jira/browse/KAFKA-4598 > Project: Kafka > Issue Type: Improvement > Components: KafkaConnect > Reporter: Shikhar Bhushan > Priority: Major > > {{SourceTask.commit()}} can be invoked concurrently with a > {{SourceTask.poll()}} in progress. Thus it is currently not possible to know > what offset state the commit call corresponds to. -- This message was sent by Atlassian Jira (v8.3.4#803005)