[camel-kafka-connector] 01/03: Fix problem when call 'context.errantRecordReporter()' will result in a NoSuchMethodException or NoClassDefFoundError when the sink connector is deployed to Connect runtimes older than Kafka 2.6

[valdar]

This is an automated email from the ASF dual-hosted git repository.

valdar pushed a commit to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 1f1868522be3d89d9ad9dbd216e07facb18b85cb
Author: Eugene <evgeny.dem...@moex.com>
AuthorDate: Fri Feb 12 19:46:27 2021 +0300

    Fix problem when call 'context.errantRecordReporter()' will result in a 
NoSuchMethodException or NoClassDefFoundError when the sink connector is 
deployed to Connect runtimes older than Kafka 2.6
---
 .../main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java 
b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
index e44676b..51ef2c5 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java
@@ -73,7 +73,12 @@ public class CamelSinkTask extends SinkTask {
             CamelSinkConnectorConfig config = 
getCamelSinkConnectorConfig(actualProps);
 
             if (context != null) {
-                reporter = context.errantRecordReporter();
+                try {
+                    reporter = context.errantRecordReporter();
+                } catch (NoSuchMethodError | NoClassDefFoundError e) {
+                    LOG.warn("Unable to instantiate ErrantRecordReporter.  
Method 'SinkTaskContext.errantRecordReporter' does not exist.");
+                    reporter = null;
+                }
             }
 
             try {