[KAFKA-16166] Generify RetryWithToleranceOperator and ErrorReporter

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.8.0
• Component/s: connect
• Assignee: Greg Harris
• Reporter: Greg Harris
• Created: 18/Jan/24 21:33
• Updated: 23/Jan/24 00:57
• Resolved: 23/Jan/24 00:57

Description

The RetryWithToleranceOperator and ErrorReporter instances in connect are only ever used with a single type of ProcessingContext (ProcessingContext<SourceRecord> for sources, ProcessingContext<ConsumerRecord<byte[], byte[]>> for sinks) and currently dynamically decide between these with instanceof checks.

Instead, these classes should be generic, and have their implementations accept consistent ProcessingContext<T> objects.

Issue Links

• links to: GitHub Pull Request #15233