fix typo in the exception of RetryUtil

.github/workflows/main_and_pr_workflow.yml

@@ -1,5 +1,6 @@
 name: Gradle
 on:
+  workflow_dispatch:
   push:
     branches: [ main ]
   pull_request:

build.gradle

@@ -134,9 +134,9 @@ ext {
     kafkaVersion = "3.5.0"
     apacheCommonsLangVersion = "3.17.0"
     slf4jVersion = "1.7.36"
-    openSearchVersion = "2.16.0"
+    openSearchVersion = "2.18.0"
 
-    testcontainersVersion = "1.20.3"
+    testcontainersVersion = "1.20.4"
 }
 
 sourceSets {
@@ -189,7 +189,7 @@ dependencies {
 
     integrationTestImplementation "org.testcontainers:junit-jupiter:$testcontainersVersion"
     integrationTestImplementation "org.testcontainers:kafka:$testcontainersVersion" // this is not Kafka version
-    integrationTestImplementation "org.opensearch:opensearch-testcontainers:2.1.1"
+    integrationTestImplementation "org.opensearch:opensearch-testcontainers:2.1.2"
     integrationTestImplementation "org.apache.kafka:kafka-clients:$kafkaVersion:test"
     integrationTestImplementation "org.apache.kafka:connect-runtime:${kafkaVersion}"
     integrationTestImplementation "org.apache.kafka:connect-runtime:${kafkaVersion}:test"

src/main/java/io/aiven/kafka/connect/opensearch/RetryUtil.java

@@ -108,7 +108,7 @@ public static <T, E extends Exception> T callWithRetry(final String callName, fi
                 return callable.call();
             } catch (final Exception e) {
                 if (!repeatableException.isAssignableFrom(e.getClass())) {
-                    final var msg = String.format("Non-repeatable exception trown by %s", callName);
+                    final var msg = String.format("Non-repeatable exception thrown by %s", callName);
                     LOGGER.error(msg, e);
                     throw new ConnectException(msg, e);
                 } else if (attempts < maxAttempts) {

src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector

@@ -0,0 +1 @@
+io.aiven.kafka.connect.opensearch.OpensearchSinkConnector