From 7a5fb5b47eed94fd3fe794f7d7235b264d2cfc39 Mon Sep 17 00:00:00 2001 From: Martin Bochenek Date: Wed, 9 Aug 2023 17:45:11 +0200 Subject: [PATCH] connectors: Iceberg connector guide --- .../connector/interceptor/iceberg_sink_hook.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/backend/pkg/connector/interceptor/iceberg_sink_hook.go b/backend/pkg/connector/interceptor/iceberg_sink_hook.go index d5ded248b..1dd0fb761 100644 --- a/backend/pkg/connector/interceptor/iceberg_sink_hook.go +++ b/backend/pkg/connector/interceptor/iceberg_sink_hook.go @@ -40,7 +40,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog uri", Documentation: "Iceberg catalog uri", Dependents: []string{}, @@ -59,7 +59,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog S3 Secret Access Key", Documentation: "", Dependents: []string{}, @@ -79,7 +79,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceMedium, - Required: true, + Required: false, DisplayName: "Iceberg catalog S3 access key id", Documentation: "", Dependents: []string{}, @@ -99,7 +99,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog S3 endpoint", Documentation: "", Dependents: []string{}, @@ -118,7 +118,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog S3 path style access", Documentation: "", Dependents: []string{}, @@ -137,7 +137,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog client region", Documentation: "", Dependents: []string{}, @@ -156,7 +156,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog credential", Documentation: "", Dependents: []string{}, @@ -175,7 +175,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con Type: "STRING", DefaultValue: "", Importance: model.ConfigDefinitionImportanceHigh, - Required: true, + Required: false, DisplayName: "Iceberg catalog warehouse", Documentation: "Iceberg catalog warehouse", Dependents: []string{},