[KAFKA-7815] SourceTask should expose ACK'd offsets, metadata

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.4.0
• Component/s: connect
• Labels: needs-kip
• Assignee: Ryanne Dolan
• Reporter: Ryanne Dolan
• Created: 11/Jan/19 20:32
• Updated: 02/Jun/21 21:44
• Resolved: 02/Jun/21 21:44

Description

Add a new callback method, recordLogged(), to notify SourceTasks when a record is ACK'd by the downstream broker. Include offsets and metadata of ACK'd record.

Issue Links

• links to: PR-6171
• mentioned in: Page Loading...