Skip to content

Commit c198d47

Browse files
committed
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).
1 parent abf54ff commit c198d47

2 files changed

Lines changed: 10 additions & 0 deletions

File tree

kamelets/couchbase-sink.kamelet.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,10 @@ spec:
7272
description: The starting id
7373
type: integer
7474
default: 1
75+
connectionString:
76+
title: Connection String
77+
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.
78+
type: string
7579
autoStartId:
7680
title: Auto Start Id
7781
description: Auto Start Id or not
@@ -92,3 +96,4 @@ spec:
9296
startingIdForInsertsFrom: "{{startingId}}"
9397
username: "{{username}}"
9498
password: "{{password}}"
99+
connectionString: "{{?connectionString}}"

library/camel-kamelets/src/main/resources/kamelets/couchbase-sink.kamelet.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,10 @@ spec:
7272
description: The starting id
7373
type: integer
7474
default: 1
75+
connectionString:
76+
title: Connection String
77+
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.
78+
type: string
7579
autoStartId:
7680
title: Auto Start Id
7781
description: Auto Start Id or not
@@ -92,3 +96,4 @@ spec:
9296
startingIdForInsertsFrom: "{{startingId}}"
9397
username: "{{username}}"
9498
password: "{{password}}"
99+
connectionString: "{{?connectionString}}"

0 commit comments

Comments
 (0)