Evgen1000end opened a new pull request #1007: URL: https://github.com/apache/camel-kafka-connector/pull/1007
According to the documentation https://kafka.apache.org/26/javadoc/org/apache/kafka/connect/sink/SinkTaskContext.html#errantRecordReporter-- changes must be made to ensure backward compatibility. Excerpt from the documentation: This method was added in Apache Kafka 2.6. Sink tasks that use this method but want to maintain backward compatibility so they can also be deployed to older Connect runtimes should guard the call to this method with a try-catch block, since calling this method will result in a NoSuchMethodException or NoClassDefFoundError when the sink connector is deployed to Connect runtimes older than Kafka 2.6. For example: try { reporter = context.errantRecordReporter(); } catch (NoSuchMethodError | NoClassDefFoundError e) { reporter = null; }` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
