Skip to content

Commit 87f0343

Browse files
authored
Pass through catalog & schema as placeholder connector configs (#197)
* Pass through catalog & schema as placeholder connector configs * Upgrade strimzi version breaking test
1 parent 7a74bde commit 87f0343

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

deploy/dev/kafka.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ metadata:
6363
strimzi.io/kraft: enabled
6464
spec:
6565
kafka:
66-
version: 4.0.0
66+
version: 4.2.0
6767
metadataVersion: "4.0"
6868
replicas: 1
6969
listeners:

hoptimator-k8s/src/main/java/com/linkedin/hoptimator/k8s/K8sConnector.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ public Map<String, String> configure() throws SQLException {
5252
new Template.SimpleEnvironment()
5353
.with("name", source.database() + "-" + source.table().toLowerCase(Locale.ROOT))
5454
.with("database", source.database())
55+
.with("catalog", source.catalog())
56+
.with("schema", source.schema())
5557
.with("table", source.table())
5658
.with(options);
5759
List<String> templates = tableTemplateApi.list()

0 commit comments

Comments
 (0)