I don't quite follow that concern. How exactly would that resending part look like? I.e. in the current code, without this PR, how would the framework go to a connector and request certain records to be resent?
Would it help if the contract would be that either `poll()` or `getSourcePartitionAndOffset()` return a non-null value in a given loop iteration? That'd seem to be the same to me as if `poll()` had actually emitted records with these new offsets. But I might well miss a thing. [ Full content available at: https://github.com/apache/kafka/pull/5553 ] This message was relayed via gitbox.apache.org for [email protected]
