[
https://issues.apache.org/jira/browse/KAFKA-16166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-16166.
---------------------------------
Fix Version/s: 3.8.0
Resolution: Fixed
> Generify RetryWithToleranceOperator and ErrorReporter
> -----------------------------------------------------
>
> Key: KAFKA-16166
> URL: https://issues.apache.org/jira/browse/KAFKA-16166
> Project: Kafka
> Issue Type: Improvement
> Components: connect
> Reporter: Greg Harris
> Assignee: Greg Harris
> Priority: Minor
> Fix For: 3.8.0
>
>
> 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
