Greg Harris created KAFKA-16166:
-----------------------------------
Summary: 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
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)
