You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/18 21:34:00 UTC

[jira] [Created] (KAFKA-16166) Generify RetryWithToleranceOperator and ErrorReporter

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)