This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new c198d4704 CAMEL-23300: add connectionString option to couchbase-sink
kamelet
c198d4704 is described below
commit c198d4704c66bb9ed4b0a54718073cf81f422383
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}}"
