diff --git a/.github/workflows/main_and_pr_workflow.yml b/.github/workflows/main_and_pr_workflow.yml index 7d865f9b..672113eb 100644 --- a/.github/workflows/main_and_pr_workflow.yml +++ b/.github/workflows/main_and_pr_workflow.yml @@ -1,5 +1,6 @@ name: Gradle on: + workflow_dispatch: push: branches: [ main ] pull_request: diff --git a/build.gradle b/build.gradle index 6ddeb414..3bb6c118 100644 --- a/build.gradle +++ b/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" diff --git a/src/main/java/io/aiven/kafka/connect/opensearch/RetryUtil.java b/src/main/java/io/aiven/kafka/connect/opensearch/RetryUtil.java index 5411a378..0243f132 100644 --- a/src/main/java/io/aiven/kafka/connect/opensearch/RetryUtil.java +++ b/src/main/java/io/aiven/kafka/connect/opensearch/RetryUtil.java @@ -108,7 +108,7 @@ public static 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) { diff --git a/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector b/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector new file mode 100644 index 00000000..54d29614 --- /dev/null +++ b/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector @@ -0,0 +1 @@ +io.aiven.kafka.connect.opensearch.OpensearchSinkConnector