This is an automated email from the ASF dual-hosted git repository. fmariani pushed a commit to branch CAMEL-23300/couchbase-sink-connection-string in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 01b37a8f9bcbe2c15e2e388dfde22647e1f41fe9 Author: Croway <[email protected]> AuthorDate: Mon Apr 13 11:29:33 2026 +0200 CAMEL-23300: add connectionString option to couchbase-sink kamelet The camel-couchbase component now supports a connectionString endpoint option (added in CAMEL-23300) that takes precedence over hostname extraction for the KV service port. This is required when Testcontainers maps ports randomly, as the SDK defaults the KV port to 11210 which is unreachable on the host side. Expose the new option as an optional kamelet property so that camel-kafka-connector and other kamelet consumers can pass the full SDK connection string (e.g. couchbase://host:mappedKvPort). --- kamelets/couchbase-sink.kamelet.yaml | 5 +++++ .../src/main/resources/kamelets/couchbase-sink.kamelet.yaml | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/kamelets/couchbase-sink.kamelet.yaml b/kamelets/couchbase-sink.kamelet.yaml index 5058d1c4f..7ad067464 100644 --- a/kamelets/couchbase-sink.kamelet.yaml +++ b/kamelets/couchbase-sink.kamelet.yaml @@ -72,6 +72,10 @@ spec: description: The starting id type: integer default: 1 + connectionString: + title: Connection String + description: The full Couchbase SDK connection string (e.g. couchbase://host:port). When set, it takes precedence over hostname extraction for the KV service port. + type: string autoStartId: title: Auto Start Id description: Auto Start Id or not @@ -92,3 +96,4 @@ spec: startingIdForInsertsFrom: "{{startingId}}" username: "{{username}}" password: "{{password}}" + connectionString: "{{?connectionString}}" diff --git a/library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml index 5058d1c4f..7ad067464 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml @@ -72,6 +72,10 @@ spec: description: The starting id type: integer default: 1 + connectionString: + title: Connection String + description: The full Couchbase SDK connection string (e.g. couchbase://host:port). When set, it takes precedence over hostname extraction for the KV service port. + type: string autoStartId: title: Auto Start Id description: Auto Start Id or not @@ -92,3 +96,4 @@ spec: startingIdForInsertsFrom: "{{startingId}}" username: "{{username}}" password: "{{password}}" + connectionString: "{{?connectionString}}"
